activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Bain <tb...@alumni.duke.edu>
Subject Re: Unmatched acknowledge: MessageAckExpected - message count (1) differs from count in dispatched-list (2)
Date Mon, 13 Mar 2017 18:36:33 GMT
Please submit this as a bug in JIRA.

Tim

On Mar 12, 2017 11:48 PM, "xabhi" <xabhi91@gmail.com> wrote:

> Observed below exceptions in STOMP consumer after failover. The consumer
> continued to receive messages but this exception kept coming on both client
> and server side and when the master activemq instance took over after
> another failover, all the messages were redelivered and below warning went
> away.
> I think it is a bug of some kind, can someone from ActiveMQ Dev team help
> here.
>
> Exception:
> [20170310 00:24:22:092 stomp_client.py:82 ERROR] Received an error:
> org.apache.activemq.transport.stomp.ProtocolException: Unexpected ACK
> received for message-id
> [ID:diogenes31.nyc.deshaw.com-41001-1489085659582-1:4:-1:1:1]
>             at
> org.apache.activemq.transport.stomp.ProtocolConverter.
> onStompAck(ProtocolConverter.java:475)
>             at
> org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(
> ProtocolConverter.java:250)
>             at
> org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(
> StompTransportFilter.java:85)
>             at
> org.apache.activemq.transport.TransportSupport.doConsume(
> TransportSupport.java:83)
>             at
> org.apache.activemq.transport.stomp.StompCodec.processCommand(StompCodec.
> java:129)
>             at
> org.apache.activemq.transport.stomp.StompCodec.parse(StompCodec.java:100)
>             at
> org.apache.activemq.transport.stomp.StompNIOTransport.processBuffer(
> StompNIOTransport.java:136)
>             at
> org.apache.activemq.transport.stomp.StompNIOTransport.
> serviceRead(StompNIOTransport.java:121)
>             at
> org.apache.activemq.transport.stomp.StompNIOTransport.
> access$000(StompNIOTransport.java:44)
>             at
> org.apache.activemq.transport.stomp.StompNIOTransport$1.
> onSelect(StompNIOTransport.java:73)
>             at
> org.apache.activemq.transport.nio.SelectorSelection.
> onSelect(SelectorSelection.java:98)
>             at
> org.apache.activemq.transport.nio.SelectorWorker$1.run(
> SelectorWorker.java:118)
>             at
> java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1142)
>             at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:617)
>             at java.lang.Thread.run(Thread.java:745)
>
> [20170310 00:24:22:096 stomp_client.py:82 ERROR] Received an error:
> javax.jms.JMSException: Unmatched acknowledge: MessageAck
> {commandId = 5, responseRequired = false, ackType = 2, consumerId =
> ID:diogenes31.nyc.deshaw.com-41001-1489085659582-1:9:-1:1, firstMessageId
> =
> null, lastMessageId =
> ID:diogenes31.nyc.deshaw.com-41001-1489085659582-1:4:-1:1:2, destination =
> topic://run1.topic.0, transactionId = null, messageCount = 1, poisonCause =
> null}
> ; Expected message count (1) differs from count in dispatched-list (2)
>             at
> org.apache.activemq.broker.region.PrefetchSubscription.
> assertAckMatchesDispatched(PrefetchSubscription.java:520)
>             at
> org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(
> PrefetchSubscription.java:212)
>             at
> org.apache.activemq.broker.region.AbstractRegion.
> acknowledge(AbstractRegion.java:528)
>             at
> org.apache.activemq.broker.region.RegionBroker.
> acknowledge(RegionBroker.java:484)
>             at
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:88)
>             at
> org.apache.activemq.broker.TransactionBroker.acknowledge(
> TransactionBroker.java:276)
>             at
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:88)
>             at
> org.apache.activemq.broker.MutableBrokerFilter.acknowledge(
> MutableBrokerFilter.java:98)
>             at
> org.apache.activemq.broker.util.LoggingBrokerPlugin.acknowledge(
> LoggingBrokerPlugin.java:162)
>             at
> org.apache.activemq.broker.MutableBrokerFilter.acknowledge(
> MutableBrokerFilter.java:98)
>             at
> deshaw.tools.jms.ActiveMQLoggingPlugin.acknowledge(
> ActiveMQLoggingPlugin.java:453)
>             at
> org.apache.activemq.broker.MutableBrokerFilter.acknowledge(
> MutableBrokerFilter.java:98)
>             at
> org.apache.activemq.broker.TransportConnection.processMessageAck(
> TransportConnection.java:590)
>             at
> org.apache.activemq.command.MessageAck.visit(MessageAck.java:245)
>             at
> org.apache.activemq.broker.TransportConnection.service(
> TransportConnection.java:336)
>             at
> org.apache.activemq.broker.TransportConnection$1.
> onCommand(TransportConnection.java:200)
>             at
> org.apache.activemq.transport.MutexTransport.onCommand(
> MutexTransport.java:45)
>             at
> org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(
> AbstractInactivityMonitor.java:301)
>             at
> org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(
> StompTransportFilter.java:97)
>             at
> org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(
> ProtocolConverter.java:202)
>             at
> org.apache.activemq.transport.stomp.ProtocolConverter.
> onStompAck(ProtocolConverter.java:456)
>             at
> org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(
> ProtocolConverter.java:250)
>             at
> org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(
> StompTransportFilter.java:85)
>             at
> org.apache.activemq.transport.TransportSupport.doConsume(
> TransportSupport.java:83)
>             at
> org.apache.activemq.transport.stomp.StompCodec.processCommand(StompCodec.
> java:129)
>             at
> org.apache.activemq.transport.stomp.StompCodec.parse(StompCodec.java:100)
>             at
> org.apache.activemq.transport.stomp.StompNIOTransport.processBuffer(
> StompNIOTransport.java:136)
>             at
> org.apache.activemq.transport.stomp.StompNIOTransport.
> serviceRead(StompNIOTransport.java:121)
>             at
> org.apache.activemq.transport.stomp.StompNIOTransport.
> access$000(StompNIOTransport.java:44)
>             at
> org.apache.activemq.transport.stomp.StompNIOTransport$1.
> onSelect(StompNIOTransport.java:73)
>             at
> org.apache.activemq.transport.nio.SelectorSelection.
> onSelect(SelectorSelection.java:98)
>             at
> org.apache.activemq.transport.nio.SelectorWorker$1.run(
> SelectorWorker.java:118)
>             at
> java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1142)
>             at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:617)
>             at java.lang.Thread.run(Thread.java:745)
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/Unmatched-acknowledge-MessageAckExpected-message-
> count-1-differs-from-count-in-dispatched-list-2-tp4723664.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message