activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: Spurious warning when using ActiveMQInputStream with ActiveMQ 4.1
Date Wed, 18 Oct 2006 07:32:46 GMT
Thanks for spotting this. I've raised a JIRA

http://issues.apache.org/activemq/browse/AMQ-987

it looks like some message groups features cause the broker to try
adding message headers that causes this exception; I'm sure we can
work around this.


On 10/17/06, Jerome Banks <jerome.banks@gmail.com> wrote:
> Just to let someone know,
>   There is spurious stack trace being logged when "createInputStream()" is
> called on an ActiveMQConnection in Active MQ 4.1. It wasn't happening in 4.0.
> As far as I can tel, the streams still seem to work, and the warning is just
> spurious
>
>
> Oct 17, 2006 11:39:03 AM
> org.apache.activemq.broker.region.QueueSubscriptionassignGroupToMe
>
> WARNING: Failed to set boolean header: *
> javax.jms.MessageNotWriteableException*: Message body is read-only
> *
>
> javax.jms.MessageNotWriteableException*: Message body is read-only
>
> at org.apache.activemq.command.ActiveMQMessage.checkReadOnlyBody(*
> ActiveMQMessage.java:573*)
>
> at org.apache.activemq.command.ActiveMQBytesMessage.initializeWriting(*
> ActiveMQBytesMessage.java:669*)
>
> at org.apache.activemq.command.ActiveMQBytesMessage.setObjectProperty(*
> ActiveMQBytesMessage.java:736*)
>
> at org.apache.activemq.command.ActiveMQMessage.setBooleanProperty(*
> ActiveMQMessage.java:533*)
>
> at org.apache.activemq.broker.region.QueueSubscription.assignGroupToMe(*
> QueueSubscription.java:137*)
>
> at org.apache.activemq.broker.region.QueueSubscription.canDispatch(*
> QueueSubscription.java:103*)
>
> at org.apache.activemq.broker.region.PrefetchSubscription.dispatch(*
> PrefetchSubscription.java:293*)
>
> at org.apache.activemq.broker.region.QueueSubscription.dispatch(*
> QueueSubscription.java:175*)
>
> at org.apache.activemq.broker.region.PrefetchSubscription.add(*
> PrefetchSubscription.java:64*)
>
> at org.apache.activemq.broker.region.Queue.addSubscription(*Queue.java:163*)
>
> at org.apache.activemq.broker.region.AbstractRegion.addConsumer(*
> AbstractRegion.java:189*)
>
> at org.apache.activemq.broker.region.RegionBroker.addConsumer(*
> RegionBroker.java:308*)
>
> at org.apache.activemq.broker.BrokerFilter.addConsumer(*BrokerFilter.java:77
> *)
>
> at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(*
> AdvisoryBroker.java:77*)
>
> at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(*
> MutableBrokerFilter.java:91*)
>
> at org.apache.activemq.broker.BrokerFilter.addConsumer(*BrokerFilter.java:77
> *)
>
> at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(*
> MutableBrokerFilter.java:91*)
>
> at org.apache.activemq.broker.AbstractConnection.processAddConsumer(*
> AbstractConnection.java:457*)
>
> at org.apache.activemq.command.ConsumerInfo.visit(*ConsumerInfo.java:295*)
>
> at org.apache.activemq.broker.AbstractConnection.service(*
> AbstractConnection.java:226*)
>
> at org.apache.activemq.broker.TransportConnection$1.onCommand(*
> TransportConnection.java:62*)
>
> at org.apache.activemq.transport.ResponseCorrelator.onCommand(*
> ResponseCorrelator.java:91*)
>
> at org.apache.activemq.transport.TransportFilter.onCommand(*
> TransportFilter.java:63*)
>
> at org.apache.activemq.transport.vm.VMTransport.oneway(*VMTransport.java:76*
> )
>
> at org.apache.activemq.transport.MutexTransport.oneway(*MutexTransport.java
> :44*)
>
> at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(*
> ResponseCorrelator.java:66*)
>
> at org.apache.activemq.transport.ResponseCorrelator.request(*
> ResponseCorrelator.java:71*)
>
> at org.apache.activemq.ActiveMQConnection.syncSendPacket(*
> ActiveMQConnection.java:1137*)
>
> at org.apache.activemq.ActiveMQInputStream.<init>(*ActiveMQInputStream.java
> :112*)
>
> at org.apache.activemq.ActiveMQConnection.doCreateInputStream(*
> ActiveMQConnection.java:1681*)
>
> at org.apache.activemq.ActiveMQConnection.createInputStream(*
> ActiveMQConnection.java:1663*)
>
> at org.apache.activemq.ActiveMQConnection.createInputStream(*
> ActiveMQConnection.java:1659*)
>
> at org.apache.activemq.ActiveMQConnection.createInputStream(*
> ActiveMQConnection.java:1655*)
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message