Smruti Ranjan Tripathy created AMQ-8276:
-------------------------------------------
Summary: Async error occurred with Unmatched acknowledge
Key: AMQ-8276
URL: https://issues.apache.org/jira/browse/AMQ-8276
Project: ActiveMQ
Issue Type: Bug
Components: Broker
Affects Versions: 5.15.15
Reporter: Smruti Ranjan Tripathy
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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
