3 Replies Latest reply on Feb 21, 2014 9:23 AM by Justin Bertram

    WARN: HQ214021: when divert to multiple address

    Rony John Newbie

      Hi 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)