Uploaded image for project: 'ActiveMQ'
  1. ActiveMQ
  2. AMQ-8276

Async error occurred with Unmatched acknowledge

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 5.15.15
    • Fix Version/s: None
    • Component/s: Broker
    • Labels:
      None

      Description

      WARN | Async error occurred | org.apache.activemq.broker.TransportConnection.Service |
      ActiveMQ Transport: ssl:///172.20.145.203:41888\njavax.jms.JMSException: Unmatched acknowledge: MessageAck {commandId = 23, responseRequired = false, ackType = 2, consumerId = ID:my-mq-test-1621569837266-1:2:1:1, firstMessageId = ID:my-mq-test-prod-1621131315514-1:12636:1:1:2, lastMessageId = ID:my-mq-test-prod-1-1621131316414-1:12683:1:1:1, destination = queue://my-mq-test-queue, transactionId = null, messageCount = 15, poisonCause = null}; Expected message count (15) differs from count in dispatched-list (14)\n\tat
      org.apache.activemq.broker.region.PrefetchSubscription.assertAckMatchesDispatched(PrefetchSubscription.java:465)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:210)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:534)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:475)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:276)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:590)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.command.MessageAck.visit(MessageAck.java:245)[activemq-client-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:336)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:200)[activemq-broker-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:125)[activemq-client-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:301)[activemq-client-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.transport.tcp.SslTransport.doConsume(SslTransport.java:171)[activemq-client-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:233)[activemq-client-5.15.15.jar:5.15.15]\n\tat
      org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)[activemq-client-5.15.15.jar:5.15.15]\n\tat java.lang.Thread.run(Thread.java:749)[:1.8.0_292]"

       

      Getting above warning, in AmazonMQ broker and at the same time or after some time, the broker stops delivering the messages to the consumer. Using client acknowledge on the consumer. This issue hardly comes once in a week. This queue contains both persistent and non-persistent messages. Time of expiry for non-persistent messages set as 0, so that they should not expiry until acknowledged. Using below queue policy

       
       
      {{<policyEntry prioritizedMessages="true" queue=">">
      <pendingQueuePolicy>
      <fileQueueCursor/>
      </pendingQueuePolicy>
      </policyEntry>}}

      Please let know, if additional information required.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              smrutiforty@gmail.com Smruti Ranjan Tripathy
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: