ARTEMIS-911 - increase ack variable on individualAcknowledge

https://issues.apache.org/jira/browse/ARTEMIS-911
2017-01-09 13:31:19 +00:00 · 2017-01-09 13:31:19 +00:00 · 83e83e7d87
parent 79647167fa
commit 83e83e7d87
1 changed files with 2 additions and 0 deletions
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
@ -868,6 +868,8 @@ public class ServerConsumerImpl implements ServerConsumer, ReadyListener {

         ref.acknowledge(tx);

+         acks++;
+
         if (startedTransaction) {
            tx.commit();
         }