You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by ryanafa <ry...@afapp.com> on 2007/06/07 21:22:03 UTC
Can Message group be used under embedded broker with vm://localhost
The ActiveMQ is embedded in Jboss and the embedded broker use URL
vm://localhost
there is a MessageNotWriteableException when u send a message with a new
message group. there is no such exception if the message group existed.
if we use tcp://localhost:61616 as embedded broker use URL everything work
fine.
the exception stacks is:
[org.apache.activemq.broker.region.QueueSubscription] Failed to set boolean
header: javax.jms.MessageNotWriteableException: Message properties are
read-only
javax.jms.MessageNotWriteableException: Message properties are read-only
at
org.apache.activemq.command.ActiveMQMessage.checkReadOnlyProperties(ActiveMQMessage.java:568)
at
org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:382)
at
org.apache.activemq.command.ActiveMQMessage.setBooleanProperty(ActiveMQMessage.java:534)
at
org.apache.activemq.broker.region.QueueSubscription.assignGroupToMe(QueueSubscription.java:134)
at
org.apache.activemq.broker.region.QueueSubscription.canDispatch(QueueSubscription.java:101)
at
org.apache.activemq.broker.region.PrefetchSubscription.dispatch(PrefetchSubscription.java:383)
at
org.apache.activemq.broker.region.QueueSubscription.dispatch(QueueSubscription.java:172)
at
org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:129)
at
org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy.dispatch(RoundRobinDispatchPolicy.java:58)
at org.apache.activemq.broker.region.Queue.dispatch(Queue.java:520)
at org.apache.activemq.broker.region.Queue.sendMessage(Queue.java:346)
at org.apache.activemq.broker.region.Queue.send(Queue.java:326)
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:292)
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:382)
at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:193)
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:98)
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136)
at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:498)
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:95)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
at
org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:96)
at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:83)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:47)
at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
at
org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1155)
at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1549)
at
org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:465)
at
org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:356)
Any hints?
Thanks.
--
View this message in context: http://www.nabble.com/Can-Message-group-be-used-under-embedded-broker-with-vm%3A--localhost-tf3885856s2354.html#a11014528
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Can Message group be used under embedded broker with
vm://localhost
Posted by ryanafa <ry...@afapp.com>.
ActiveMQ 4.1.1
JBoss 4.2.0.GA
could you tell me which version work? Thanks.
James.Strachan wrote:
>
> On 6/7/07, ryanafa <ry...@afapp.com> wrote:
>>
>> The ActiveMQ is embedded in Jboss and the embedded broker use URL
>> vm://localhost
>> there is a MessageNotWriteableException when u send a message with a new
>> message group. there is no such exception if the message group existed.
>>
>> if we use tcp://localhost:61616 as embedded broker use URL everything
>> work
>> fine.
>
> Which version are you using btw? I thought this got fixed a while back?
>
>
>> the exception stacks is:
>> [org.apache.activemq.broker.region.QueueSubscription] Failed to set
>> boolean
>> header: javax.jms.MessageNotWriteableException: Message properties are
>> read-only
>> javax.jms.MessageNotWriteableException: Message properties are read-only
>> at
>> org.apache.activemq.command.ActiveMQMessage.checkReadOnlyProperties(ActiveMQMessage.java:568)
>> at
>> org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:382)
>> at
>> org.apache.activemq.command.ActiveMQMessage.setBooleanProperty(ActiveMQMessage.java:534)
>> at
>> org.apache.activemq.broker.region.QueueSubscription.assignGroupToMe(QueueSubscription.java:134)
>> at
>> org.apache.activemq.broker.region.QueueSubscription.canDispatch(QueueSubscription.java:101)
>> at
>> org.apache.activemq.broker.region.PrefetchSubscription.dispatch(PrefetchSubscription.java:383)
>> at
>> org.apache.activemq.broker.region.QueueSubscription.dispatch(QueueSubscription.java:172)
>> at
>> org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:129)
>> at
>> org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy.dispatch(RoundRobinDispatchPolicy.java:58)
>> at
>> org.apache.activemq.broker.region.Queue.dispatch(Queue.java:520)
>> at
>> org.apache.activemq.broker.region.Queue.sendMessage(Queue.java:346)
>> at org.apache.activemq.broker.region.Queue.send(Queue.java:326)
>> at
>> org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:292)
>> at
>> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:382)
>> at
>> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:193)
>> at
>> org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
>> at
>> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:98)
>> at
>> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136)
>> at
>> org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:498)
>> at
>> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604)
>> at
>> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
>> at
>> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
>> at
>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:95)
>> at
>> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
>> at
>> org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:96)
>> at
>> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:83)
>> at
>> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:47)
>> at
>> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>> at
>> org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1155)
>> at
>> org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1549)
>> at
>> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:465)
>> at
>> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:356)
>>
>>
>> Any hints?
>>
>>
>> Thanks.
>> --
>> View this message in context:
>> http://www.nabble.com/Can-Message-group-be-used-under-embedded-broker-with-vm%3A--localhost-tf3885856s2354.html#a11014528
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
>
>
> --
> James
> -------
> http://macstrac.blogspot.com/
>
>
--
View this message in context: http://www.nabble.com/Can-Message-group-be-used-under-embedded-broker-with-vm%3A--localhost-tf3885856s2354.html#a11014980
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Can Message group be used under embedded broker with vm://localhost
Posted by James Strachan <ja...@gmail.com>.
On 6/7/07, ryanafa <ry...@afapp.com> wrote:
>
> The ActiveMQ is embedded in Jboss and the embedded broker use URL
> vm://localhost
> there is a MessageNotWriteableException when u send a message with a new
> message group. there is no such exception if the message group existed.
>
> if we use tcp://localhost:61616 as embedded broker use URL everything work
> fine.
Which version are you using btw? I thought this got fixed a while back?
> the exception stacks is:
> [org.apache.activemq.broker.region.QueueSubscription] Failed to set boolean
> header: javax.jms.MessageNotWriteableException: Message properties are
> read-only
> javax.jms.MessageNotWriteableException: Message properties are read-only
> at
> org.apache.activemq.command.ActiveMQMessage.checkReadOnlyProperties(ActiveMQMessage.java:568)
> at
> org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:382)
> at
> org.apache.activemq.command.ActiveMQMessage.setBooleanProperty(ActiveMQMessage.java:534)
> at
> org.apache.activemq.broker.region.QueueSubscription.assignGroupToMe(QueueSubscription.java:134)
> at
> org.apache.activemq.broker.region.QueueSubscription.canDispatch(QueueSubscription.java:101)
> at
> org.apache.activemq.broker.region.PrefetchSubscription.dispatch(PrefetchSubscription.java:383)
> at
> org.apache.activemq.broker.region.QueueSubscription.dispatch(QueueSubscription.java:172)
> at
> org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:129)
> at
> org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy.dispatch(RoundRobinDispatchPolicy.java:58)
> at org.apache.activemq.broker.region.Queue.dispatch(Queue.java:520)
> at org.apache.activemq.broker.region.Queue.sendMessage(Queue.java:346)
> at org.apache.activemq.broker.region.Queue.send(Queue.java:326)
> at
> org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:292)
> at
> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:382)
> at
> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:193)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
> at
> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:98)
> at
> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136)
> at
> org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:498)
> at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604)
> at
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:95)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
> at
> org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:96)
> at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:83)
> at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:47)
> at
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
> at
> org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1155)
> at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1549)
> at
> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:465)
> at
> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:356)
>
>
> Any hints?
>
>
> Thanks.
> --
> View this message in context: http://www.nabble.com/Can-Message-group-be-used-under-embedded-broker-with-vm%3A--localhost-tf3885856s2354.html#a11014528
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
James
-------
http://macstrac.blogspot.com/