ARTEMIS-1902 decrement before returning

2018-06-04 15:01:04 -05:00 · 2018-06-04 15:01:04 -05:00 · be36d3078c
parent 655f1dc46a
commit be36d3078c
1 changed files with 1 additions and 1 deletions
--- 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;