From 5a19c54f9faf549aea5d14682593815e1de3a1c6 Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Wed, 23 Jan 2019 13:28:28 -0500 Subject: [PATCH] ARTEMIS-196 Removing dead variables Fixing build after removing variable used by FieldUpdater --- .../activemq/artemis/core/server/impl/QueueImpl.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java index b7cef25d09..8209995e42 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java @@ -227,6 +227,9 @@ public class QueueImpl extends CriticalComponentImpl implements Queue { private ScheduledFuture redistributorFuture; + // This is used by an AtomicFieldUpdater + private volatile long consumerRemovedTimestamp = -1; + private final QueueConsumers> consumers = new QueueConsumersImpl<>(); private final Map groups = new HashMap<>(); @@ -271,6 +274,10 @@ public class QueueImpl extends CriticalComponentImpl implements Queue { private final QueueFactory factory; + public volatile int dispatching = 0; + + public volatile long dispatchStartTime = -1; + private volatile int consumersBeforeDispatch = 0; private volatile long delayBeforeDispatch = 0;