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

Setting nonBlockingRedelivery to true doesn't rollback the messages if the Openwire consumer is killed mid processing.

    XMLWordPrintable

    Details

      Description

      If the client JVM is killed  when a message is still processing through an Openwire consumer,

      the messages still remain in the delivering state until the broker is restarted. 

      This only happens when the nonBlockingRedelivery is set to true.

       

      NAME ADDRESS CONSUMER_COUNT MESSAGE_COUNT MESSAGES_ADDED DELIVERING_COUNT
      TEST TEST 0 1 1 1

       

       

      This is what the printdata shows when the message is stuck in the delivering state without any consumer:

       

      ### Surviving Records Summary ###
      2021-04-09 15:21:22,550 WARN  [org.apache.activemq.artemis.journal] AMQ142015: Uncommitted transaction with id 70 found and discarded
      recordID=30;userRecordType=45;isUpdate=false;compactCount=0;Message(messageID=30;userMessageID=f36f3b67-9918-11eb-b08a-66662017fc17;msg=CoreMessage[messageID=30,durable=true,userID=f36f3b67-9918-11eb-b08a-66662017fc17,priority=4, timestamp=Fri Apr 09 15:20:00 IST 2021,expiration=0, durable=true, address=TEST,size=643,properties=TypedProperties[__AMQ_CID=ID:adongre-32751-1617961800046-0:1,_AMQ_GROUP_SEQUENCE=0,__HDR_BROKER_IN_TIME=1617961800734,_AMQ_ROUTING_TYPE=1,__HDR_ARRIVAL=0,__HDR_COMMAND_ID=5,__HDR_PRODUCER_ID=[0000 0036 7B01 0022 4944 3A61 646F 6E67 7265 2D33 3237 3531 2D31 3631 3739 3631 3830 3030 3436 2D31 3A31 0000 0000 0000 0001 0000 0000 0000 0001),__HDR_MESSAGE_ID=[0000 0049 6E00 017B 0100 2249 443A 6164 6F6E 6772 652D 3332 3735 312D 3136  ... 00 0000 0000 0100 0000 0000 0000 0100 0000 0000 0000 0100 0000 0000 0000 00),__HDR_DROPPABLE=false]]@1187903677
      recordID=30;userRecordType=32;isUpdate=true;compactCount=0;AddRef;QueueEncoding [queueID=27]
      
      ### Prepared TX ###
      
      ### Failed Transactions (Missing commit/prepare/rollback record) ###
      Transaction 70 failed with these records:
      - recordID=30;userRecordType=33;isUpdate=true;compactCount=0;ACK;QueueEncoding [queueID=27]

       

       

        Attachments

          Issue Links

            Activity

              People

              Assignee:
              garytully Gary Tully
              Reporter:
              avi5kdon Avinash Dongre
              Tester:
              Roman Vais Roman Vais
              Votes:
              1 Vote for this issue
              Watchers:
              5 Start watching this issue

                Dates

                Created:
                Updated:
                Resolved: