activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: ARTEMIS-1902 decrement before returning
Date Mon, 04 Jun 2018 20:25:41 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 655f1dc46 -> 46a41aeca


ARTEMIS-1902 decrement before returning


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

Branch: refs/heads/master
Commit: be36d3078ceafe3df06a1686426f5d948dfadc2c
Parents: 655f1dc
Author: Justin Bertram <jbertram@apache.org>
Authored: Mon Jun 4 15:01:04 2018 -0500
Committer: Justin Bertram <jbertram@apache.org>
Committed: Mon Jun 4 15:01:04 2018 -0500

----------------------------------------------------------------------
 .../org/apache/activemq/artemis/core/postoffice/QueueInfo.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/be36d307/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/QueueInfo.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/QueueInfo.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/QueueInfo.java
index 581d648..f271ebe 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/QueueInfo.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/QueueInfo.java
@@ -114,7 +114,7 @@ public class QueueInfo implements Serializable {
 
       consumerUpdater.getAndUpdate(this, value -> {
          if (value > 0) {
-            return value--;
+            return --value;
          } else {
             ActiveMQServerLogger.LOGGER.consumerCountError("Tried to decrement consumer count
below 0: " + this);
             return value;


Mime
View raw message