[
https://issues.apache.org/jira/browse/AMQ-8276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368355#comment-17368355
]
Smruti Ranjan Tripathy edited comment on AMQ-8276 at 6/23/21, 5:19 PM:
-----------------------------------------------------------------------
Only getting this issue when standby broker is active. Using active/standby
failover configuration in Amazon MQ.
was (Author: [email protected]):
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)
