activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ryanafa <r...@afapp.com>
Subject Can Message group be used under embedded broker with vm://localhost
Date Thu, 07 Jun 2007 19:22:03 GMT

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.


Mime
View raw message