activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From martyntay...@apache.org
Subject [2/3] activemq-artemis git commit: ARTEMIS-911 - increase ack variable on individualAcknowledge
Date Mon, 09 Jan 2017 14:54:23 GMT
ARTEMIS-911 - increase ack variable on individualAcknowledge

https://issues.apache.org/jira/browse/ARTEMIS-911


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/83e83e7d
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/83e83e7d
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/83e83e7d

Branch: refs/heads/master
Commit: 83e83e7d87555edc40fc2f5198fa6ec26efe9a91
Parents: 7964716
Author: Andy Taylor <andy.tayls67@gmail.com>
Authored: Mon Jan 9 13:31:19 2017 +0000
Committer: Andy Taylor <andy.tayls67@gmail.com>
Committed: Mon Jan 9 13:40:14 2017 +0000

----------------------------------------------------------------------
 .../activemq/artemis/core/server/impl/ServerConsumerImpl.java      | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/83e83e7d/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
----------------------------------------------------------------------
diff --git 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
index 3e5b20a..bcc6df1 100644
--- 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();
          }


Mime
View raw message