Markus Gerstel created AMQ-6796:
-----------------------------------
Summary: Acknowledging messages out of order in a STOMP 1.1
transaction raises exception
Key: AMQ-6796
URL: https://issues.apache.org/jira/browse/AMQ-6796
Project: ActiveMQ
Issue Type: Bug
Components: stomp
Affects Versions: 5.15.0
Reporter: Markus Gerstel
Reproducing the problem:
* Receive two messages via STOMP on a subscription with ack:client-individual
* Start a transaction
* Acknowledge message #2
* Acknowledge message #1
* Commit the transaction
Unit test available at
https://github.com/Anthchirp/activemq/commits/stomptxackooo
Expected behaviour:
* Both messages are acknowledged, life goes on
Observed behaviour:
* Exception is raised:
{{code:java}}
javax.jms.JMSException: Unmatched acknowledge: MessageAck {commandId = 0,
responseRequired = false, ackType = 2, consumerId = ID:(...)-6:555:-1:1,
firstMessageId = null, lastMessageId = ID:(...)-6:555:-1:1:1, destination =
queue://(...), transactionId = null, messageCount = 2, poisonCause = null};
Expected message count (2) differs from count in dispatched-list (1)
at
org.apache.activemq.broker.region.PrefetchSubscription.assertAckMatchesDispatched(PrefetchSubscription.java:519)
at
org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:211)
at
org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:528)
at
org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:475)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)
at
org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:276)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:89)
at
org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:581)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:245)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:330)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:194)
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.StompSubscription.onStompCommit(StompSubscription.java:125)
at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommit(ProtocolConverter.java:521)
at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:256)
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.tcp.TcpTransport.doRun(TcpTransport.java:233)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)
at java.lang.Thread.run(Thread.java:748)
{{code}}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
