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

Openwire (killed) consumer - messages delivered out of order

    XMLWordPrintable

Details

    Description

      This can be observed in the following log sequence:

      # Message 14381/14391 received by broker's INBOUND queue, in order
      2023-10-11 12:15:43,029 [TRACER](Thread-12 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@bdecc21)) AMQ991001: amqbroker: INBOUND_QUEUE: messageId=291806,SERV_NAME=service a,CRAQ_MSGID=14381: received by broker from /10.22.8.152:44292 (status OK)
      
      2023-10-11 12:15:43,053 [TRACER](Thread-5 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@bdecc21)) AMQ991001: amqbroker: INBOUND_QUEUE: messageId=291879,SERV_NAME=service a,CRAQ_MSGID=14391: received by broker from /10.22.8.152:44292 (status OK)
      
      # Message 14381 sent to consumer
      2023-10-11 12:15:53,053 [TRACER](Thread-3 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@bdecc21)) AMQ991000: amqbroker: INBOUND_QUEUE: messageId=291806,SERV_NAME=service a,CRAQ_MSGID=14381: sent to consumer at /10.22.8.152:39288
      
      
      // Consumer killed
      2023-10-11 12:15:53,059 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 707c2ded-6851-11ee-9b8d-fa163e7f25f4
      
      
      # Message 14391 sent to consumer
      2023-10-11 12:15:53,547 [TRACER](Thread-27 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@bdecc21)) AMQ991000: amqbroker: INBOUND_QUEUE: messageId=291879,SERV_NAME=service a,CRAQ_MSGID=14391: sent to consumer at /10.22.8.152:39290
      
      # Message 14381 sent to consumer again, OUT OF ORDER!
      2023-10-11 12:15:53,548 [TRACER](Thread-27 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@bdecc21)) AMQ991000: amqbroker: INBOUND_QUEUE: messageId=291806,SERV_NAME=service a,CRAQ_MSGID=14381: sent to consumer at /10.22.8.152:39290
      
      # Message 14391 received by broker REPLY QUEUE
      2023-10-11 12:15:54,091 [TRACER](Thread-12 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@bdecc21)) AMQ991001: amqbroker: REPLY_QUEUE: messageId=334775,SERV_NAME=service a,CRAQ_MSGID=14391: received by broker from /10.22.8.152:39290 (status OK)
      
      # Message 14381 received by broker REPLY QUEUE
      2023-10-11 12:15:54,117 [TRACER](Thread-2 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@bdecc21)) AMQ991001: amqbroker: REPLY_QUEUE: messageId=334867,SERV_NAME=service a,CRAQ_MSGID=14381: received by broker from /10.22.8.152:39290 (status OK)
      
      
      # After the message has been enqueued in REPLY queue, receives acks for 14391 and 14381
      2023-10-11 12:15:54,138 [TRACER](Thread-21 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@bdecc21)) AMQ991002: amqbroker: INBOUND_QUEUE: messageId=291879,SERV_NAME=service a,CRAQ_MSGID=14391: ack received from consumer at /10.22.8.152:39290
      
      2023-10-11 12:15:54,139 [TRACER](Thread-21 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@bdecc21)) AMQ991002: amqbroker: INBOUND_QUEUE: messageId=291806,SERV_NAME=service a,CRAQ_MSGID=14381: ack received from consumer at /10.22.8.152:39290
      

      Attachments

        Activity

          People

            gtully@redhat.com Gary Tully
            rhn-support-shiggs Stephen Higgs
            Roman Vais Roman Vais
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: