Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-196 Removing dead variables 

Fixing build after removing variable used by FieldUpdater
This commit is contained in:
Clebert Suconic 2019-01-23 13:28:28 -05:00
parent 99b24adfba
commit 5a19c54f9f
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
View File

@ -227,6 +227,9 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
private ScheduledFuture<?> redistributorFuture; private ScheduledFuture<?> redistributorFuture;
// This is used by an AtomicFieldUpdater
private volatile long consumerRemovedTimestamp = -1;
private final QueueConsumers<ConsumerHolder<? extends Consumer>> consumers = new QueueConsumersImpl<>(); private final QueueConsumers<ConsumerHolder<? extends Consumer>> consumers = new QueueConsumersImpl<>();
private final Map<SimpleString, Consumer> groups = new HashMap<>(); private final Map<SimpleString, Consumer> groups = new HashMap<>();
@ -271,6 +274,10 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
private final QueueFactory factory; private final QueueFactory factory;
public volatile int dispatching = 0;
public volatile long dispatchStartTime = -1;
private volatile int consumersBeforeDispatch = 0; private volatile int consumersBeforeDispatch = 0;
private volatile long delayBeforeDispatch = 0; private volatile long delayBeforeDispatch = 0;