WARN: HQ214021: when divert to multiple address
ronyjhn Feb 20, 2014 12:31 AMHi All,
To divert single source queue to multiple queue, I am using following configuration in hornetq-configuration.xml
<diverts>
<divert name="testing-divert1">
<address>jms.queue.master_queue</address>
<routing-name>testing-divert1</routing-name>
<exclusive>true</exclusive>
<forwarding-address>jms.queue.node1</forwarding-address>
</divert>
<divert name="testing-divert2">
<address>jms.queue.master_queue</address>
<routing-name>testing-divert2</routing-name>
<exclusive>true</exclusive>
<forwarding-address>jms.queue.node2</forwarding-address>
</divert>
</diverts>
I have two JMS client code, listener is configured to read message from 'jms.queue.master_queue' and post message to jms.queue.node1/jms.queue.node2 from each client.
What could be the reason for following warning message.
20 Feb, 2014 10:15:42 AM org.hornetq.core.client.impl.ClientSessionImpl startCall
WARN: HQ214021: Invalid concurrent session usage. Sessions are not supposed to be used by more than one thread concurrently.
java.lang.Exception: trace
at org.hornetq.core.client.impl.ClientSessionImpl.startCall(ClientSessionImpl.java:1313)
at org.hornetq.core.client.impl.ClientSessionImpl.acknowledge(ClientSessionImpl.java:799)
at org.hornetq.core.client.impl.ClientConsumerImpl.doAck(ClientConsumerImpl.java:1208)
at org.hornetq.core.client.impl.ClientConsumerImpl.acknowledge(ClientConsumerImpl.java:821)
at org.hornetq.core.client.impl.ClientMessageImpl.acknowledge(ClientMessageImpl.java:96)
at org.hornetq.jms.client.JMSMessageListenerWrapper.onMessage(JMSMessageListenerWrapper.java:133)
at org.hornetq.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1085)
at org.hornetq.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:57)
at org.hornetq.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1220)
at org.hornetq.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:106)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)