You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2018/06/19 16:39:03 UTC
qpid-broker-j git commit: QPID-8210: [Broker-J] Make field
QueueConsumerImpl#_queueConsumerNode volatile
Repository: qpid-broker-j
Updated Branches:
refs/heads/master 0c4e41829 -> a07e8fd80
QPID-8210: [Broker-J] Make field QueueConsumerImpl#_queueConsumerNode volatile
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/a07e8fd8
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/a07e8fd8
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/a07e8fd8
Branch: refs/heads/master
Commit: a07e8fd80ea11f0458c0fcfe4bc7a0ec31b4a7bb
Parents: 0c4e418
Author: Alex Rudyy <or...@apache.org>
Authored: Tue Jun 19 17:38:29 2018 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Tue Jun 19 17:38:29 2018 +0100
----------------------------------------------------------------------
.../main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/a07e8fd8/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java
----------------------------------------------------------------------
diff --git a/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java b/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java
index e6974e7..2f637ee 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java
@@ -101,7 +101,7 @@ class QueueConsumerImpl<T extends ConsumerTarget>
private final String _linkName;
- private QueueConsumerNode _queueConsumerNode;
+ private volatile QueueConsumerNode _queueConsumerNode;
QueueConsumerImpl(final AbstractQueue<?> queue,
T target,
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org