Github user clebertsuconic commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2119#discussion_r192559076
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/QueueInfo.java
---
@@ -107,7 +108,11 @@ public void incrementConsumers() {
}
public void decrementConsumers() {
- numberOfConsumers--;
+ if (numberOfConsumers > 0) {
--- End diff --
The atomic updater would be better then atomic integer. I think thatâs
what Michael is referring.
---