DEBUG ActiveMQConnection
生产者,消费者mq 数据接收数据时 出现下面的错误,请问这个到底是什么错误 ,怎么解决。
21:45:19 DEBUG ActiveMQConnection - Async exception with no exception listener: javax.jms.JMSException: Could not correlate acknowledgment with dispatched message: MessageAck {commandId = 2116, responseRequired = false, ackType = 0, consumerId = ID:basopen2-50821-1373982314076-1:1:1:1, firstMessageId = null, lastMessageId = e241dbea-e6fc-5021-500c-e3ea2497cf8d:0:22:2082303977, destination = queue://00250, transactionId = null, messageCount = 1}
javax.jms.JMSException: Could not correlate acknowledgment with dispatched message: MessageAck {commandId = 2116, responseRequired = false, ackType = 0, consumerId = ID:basopen2-50821-1373982314076-1:1:1:1, firstMessageId = null, lastMessageId = e241dbea-e6fc-5021-500c-e3ea2497cf8d:0:22:2082303977, destination = queue://msg_od_250, transactionId = null, messageCount = 1}at org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:316)
at org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:373)
at org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:470)
at org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:194)
at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
at org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:85)
at org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:452)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:205)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:300)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:216)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:204)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:186)
at java.lang.Thread.run(Thread.java:595)
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
ACK 不属于这次dispatch的消息ID