0 
警告 | 发生异步错误 | org.apache.activemq.broker.TransportConnection.Service |
ActiveMQ 传输：ssl:///172.20.145.203:41888\njavax.jms.JMSException：不匹配的确认：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，目的地 = queue://my-mq-test-queue，transactionId = null，messageCount = 15，toxicCause = null}；预期的消息计数 (15) 与调度列表中的计数 (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]"

收到上述警告，在 AmazonMQ 代理中，同时或一段时间后，代理停止将消息传递给消费者。对消费者使用客户端确认。这个问题几乎每周出现一次。此队列包含持久性和非持久性消息。非持久消息的过期时间设置为 0，因此它们在确认之前不会过期。使用以下队列策略

 <policyEntry prioritizedMessages="true" queue="&gt;">
          <pendingQueuePolicy>
            <fileQueueCursor/>
          </pendingQueuePolicy>
        </policyEntry>

代理配置

4

0 回答 0