You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Smruti Ranjan Tripathy (Jira)" <ji...@apache.org> on 2021/06/23 17:20:00 UTC
[jira] [Commented] (AMQ-8276) Async error occurred with Unmatched
acknowledge
[ https://issues.apache.org/jira/browse/AMQ-8276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368355#comment-17368355 ]
Smruti Ranjan Tripathy commented on AMQ-8276:
---------------------------------------------
OOnly getting this issue when standby broker is active. Using active/standby failover configuration in Amazon MQ.
> 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
> Priority: Major
>
> 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)