You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2016/04/26 16:04:26 UTC
activemq git commit: https://issues.apache.org/jira/browse/AMQ-6251
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 <ta...@gmail.com>
Authored: Tue Apr 26 10:03:47 2016 -0400
Committer: Timothy Bish <ta...@gmail.com>
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