mirror of https://github.com/apache/activemq.git
Make field volatile since it is written to outside of any locks and read both in and out of locking.
This commit is contained in:
parent
4e27618ddd
commit
8031d77f98
|
@ -132,7 +132,7 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
|
||||||
private boolean allConsumersExclusiveByDefault = false;
|
private boolean allConsumersExclusiveByDefault = false;
|
||||||
private final AtomicBoolean started = new AtomicBoolean();
|
private final AtomicBoolean started = new AtomicBoolean();
|
||||||
|
|
||||||
private boolean resetNeeded;
|
private volatile boolean resetNeeded;
|
||||||
|
|
||||||
private final Runnable sendMessagesWaitingForSpaceTask = new Runnable() {
|
private final Runnable sendMessagesWaitingForSpaceTask = new Runnable() {
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue