Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-2052

Message load balancing off, unable to send messages to queue on other nodes instead of subscribed consumer

    XMLWordPrintable

Details

    • Release Notes, Compatibility/Configuration, User Experience
    • Hide
      In releases prior to AMQ Broker 7.2.3, a recursive call would result in a StackOverflowError error message in certain conditions when message load balancing was set to `OFF.` As a result, the broker would not receive messages sent from clients.
      In AMQ Broker 7.2.3, a verification step has been added to ensure that a recursive call will not become infinite. Now brokers receive any message sent by a client even when message load balancing is set to `OFF.`
      Show
      In releases prior to AMQ Broker 7.2.3, a recursive call would result in a StackOverflowError error message in certain conditions when message load balancing was set to `OFF.` As a result, the broker would not receive messages sent from clients. In AMQ Broker 7.2.3, a verification step has been added to ensure that a recursive call will not become infinite. Now brokers receive any message sent by a client even when message load balancing is set to `OFF.`
    • Documented as Resolved Issue

    Description

      Test scenario assumes autocreate is turned on.

      1. Subscribe consumer to queue X on broker1 (Master1)
        java  -jar /var/dtests/node_data/clients/acce.jar receiver --log-msgs dict --broker 10.37.145.211:61616 --conn-username admin --conn-password admin --address lalaQ --count 100 --timeout 500
        
      2. Send message to queue X on broker1 - passes
        java  -jar /var/dtests/node_data/clients/acce.jar sender --timeout 120 --log-msgs dict --broker 10.37.145.211:61616 --conn-username admin --conn-password admin --address lalaQ --count 1
        
      3. Send message to queue X on broker2 - failure
        java  -jar /var/dtests/node_data/clients/acce.jar sender --timeout 120 --log-msgs dict --broker 10.37.145.217:61616 --conn-username admin --conn-password admin --address lalaQ --count 1
        16:36:44,932 ERROR ActiveMQInternalErrorException[errorType=INTERNAL_ERROR message=null]
        16:36:44,935 ERROR Error while sending a message!
        javax.jms.JMSException
        	at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:423)
        	at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:319)
        	at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.sendFullMessage(ActiveMQSessionContext.java:479)
        	at org.apache.activemq.artemis.core.client.impl.ClientProducerImpl.sendRegularMessage(ClientProducerImpl.java:304)
        	at org.apache.activemq.artemis.core.client.impl.ClientProducerImpl.doSend(ClientProducerImpl.java:276)
        	at org.apache.activemq.artemis.core.client.impl.ClientProducerImpl.send(ClientProducerImpl.java:129)
        	at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.doSendx(ActiveMQMessageProducer.java:517)
        	at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:192)
        	at com.redhat.mqe.acc.AccSenderClient.startClient(AccSenderClient.java:99)
        	at com.redhat.mqe.lib.Main.main(Main.java:46)
        	at com.redhat.mqe.acc.Main.main(Main.java:85)
        	at com.redhat.mqe.acc.Main.main(Main.java:89)
        Caused by: ActiveMQInternalErrorException[errorType=INTERNAL_ERROR message=null]
        	... 12 more
        
      4. Disconnect subscribed consumer from broker1
      5. Try previous step again (send message to X on broker2) - passes

      I was able to reproduce this with the latest 7.2.2 broker provided yesterday.
      This seems like a weird "locking mechanism" only when message-load-balancing is set to OFF.

      You can download clients from here:
      http://messaging-qe-repo.usersys.redhat.com:8081/artifactory/cli-java/

      aac1.jar = cli-qpid-jms-1.2.2-SNAPSHOT-0.37.0.redhat-00001.jar AMQP
      acce.jar = cli-artemis-jms-1.2.2-SNAPSHOT-2.6.3.redhat-00004.jar Core
      aoc7.jar = cli-activemq-1.2.2-SNAPSHOT-5.11.0.redhat-630329.jar Openwire

      Openwire & AMQP broker log exceptions only provide:

      2018-10-16 16:53:42,666 WARN  [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=GENERIC_EXCEPTION]
      2018-10-16 16:53:42,668 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 46350252-d153-11e8-86f0-5254001fbc3f
      2018-10-16 16:53:42,668 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 46350252-d153-11e8-86f0-5254001fbc3f
      2018-10-16 16:53:42,669 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 463884c3-d153-11e8-86f0-5254001fbc3f
      2018-10-16 16:53:42,669 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 463884c3-d153-11e8-86f0-5254001fbc3f
      2018-10-16 16:53:57,360 WARN  [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=GENERIC_EXCEPTION]
      2018-10-16 16:53:57,363 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 4efe75b4-d153-11e8-86f0-5254001fbc3f
      2018-10-16 16:53:57,363 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 4efe75b4-d153-11e8-86f0-5254001fbc3f
      2018-10-16 16:53:57,364 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 4f03cce5-d153-11e8-86f0-5254001fbc3f
      2018-10-16 16:53:57,364 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 4f03cce5-d153-11e8-86f0-5254001fbc3f
      2018-10-16 16:54:11,047 WARN  [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=GENERIC_EXCEPTION]
      

      Attachments

        1. artemis.log
          183 kB
        2. broker.xml
          8 kB

        Issue Links

          Activity

            People

              rhn-support-jbertram Justin Bertram
              mtoth@redhat.com Michal Toth
              Michal Toth Michal Toth
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: