Repository: activemq Updated Branches: refs/heads/master 4e27618dd -> 8031d77f9
https://issues.apache.org/jira/browse/AMQ-6251 Make field volatile since it is written to outside of any locks and read both in and out of locking. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/8031d77f Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/8031d77f Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/8031d77f Branch: refs/heads/master Commit: 8031d77f984e4d3c54782dd4934f48b35cf16c00 Parents: 4e27618 Author: Timothy Bish <[email protected]> Authored: Tue Apr 26 10:03:47 2016 -0400 Committer: Timothy Bish <[email protected]> Committed: Tue Apr 26 10:04:21 2016 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/activemq/broker/region/Queue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/8031d77f/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java index 097dfa5..af37bdc 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java @@ -132,7 +132,7 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index private boolean allConsumersExclusiveByDefault = false; private final AtomicBoolean started = new AtomicBoolean(); - private boolean resetNeeded; + private volatile boolean resetNeeded; private final Runnable sendMessagesWaitingForSpaceTask = new Runnable() { @Override
