Repository: activemq Updated Branches: refs/heads/activemq-5.13.x e633e49af -> d38c5906f
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. (cherry picked from commit 8031d77f984e4d3c54782dd4934f48b35cf16c00) Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/bb58db75 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/bb58db75 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/bb58db75 Branch: refs/heads/activemq-5.13.x Commit: bb58db75a677e3cc147f3ca0a56ffb9afa12d287 Parents: e633e49 Author: Timothy Bish <tabish...@gmail.com> Authored: Tue Apr 26 10:03:47 2016 -0400 Committer: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com> Committed: Thu Apr 28 11:46:42 2016 +0000 ---------------------------------------------------------------------- .../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/bb58db75/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 d61c49e..8da9b1a 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
