salma Ali created AMQ-5780:
------------------------------
Summary: Unmatched acknowledge (end of ack) , when connect to AMQ
using WS over Stomp
Key: AMQ-5780
URL: https://issues.apache.org/jira/browse/AMQ-5780
Project: ActiveMQ
Issue Type: Bug
Components: activemq-camel
Affects Versions: 5.11.1
Reporter: salma Ali
i have ActiveMQ 5.11.1 , and connect to it through ws over Stomp , and after
many requests the AMQ through the following Exception and the client couldn't
get the message :
javax.jms.JMSException: Unmatched acknowledge: MessageAck {commandId = 0,
responseRequired = false, ackType = 2, consumerId =
ID:QVM1-59068-1431443290141-4:1:-1:4, firstMessageId = null, lastMessageId =
ID:QVM1-59072-1431443299564-14:1:5:1:2, destination =
temp-queue://ID:QVM1-59068-1431443290141-4:1:2, transactionId = null,
messageCount = 1, poisonCause = null}; Could not find Message-ID
ID:QVM1-59072-1431443299564-14:1:5:1:2 in dispatched-list (end of ack)
at org.apache.activemq
broker.region.PrefetchSubscription.assertAckMatchesDispatched(PrefetchSubscription.java:481)[activemq
broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:212)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:441)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:484)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:87)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:87)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:87)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:277)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:550)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.command.MessageAck.visit(MessageAck.java:245)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ws.jetty8.StompSocket.sendToActiveMQ(StompSocket.java:117)[activemq-http-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.stomp.StompSubscription.onMessageDispatch(StompSubscription.java:78)[activemq-stomp-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.stomp.ProtocolConverter.onActiveMQCommand(ProtocolConverter.java:870)[activemq-stomp-5.11.1.jar:5.11.1]
at
org.apache.activemq.transport.ws.jetty8.StompSocket.oneway(StompSocket.java:109)[activemq-http-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1419)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:938)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:984)[activemq-broker-5.11.1.jar:5.11.1]
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)[activemq-client-5.11.1.jar:5.11.1]
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)[activemq-client-5.11.1.jar:5.11.1]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_17]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_17]
at java.lang.Thread.run(Thread.java:722)[:1.7.0_17]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
