[prev in list] [next in list] [prev in thread] [next in thread]
List: activemq-commits
Subject: [1/4] activemq git commit: https://issues.apache.org/jira/browse/AMQ-6251
From: cshannon () apache ! org
Date: 2016-04-28 11:49:19
Message-ID: c3f42aac6bb649debcff81211765169d () git ! apache ! org
[Download RAW message or body]
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 <tabish121@gmail.com>
Authored: Tue Apr 26 10:03:47 2016 -0400
Committer: Christopher L. Shannon (cshannon) <christopher.l.shannon@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
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic