Github user mtaylor commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2119#discussion_r192558538
--- 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 --
@michaelandrepearce +1. I will make this an AtomicInteger cheers.---
