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:41:24 UTC

[2/2] qpid-broker-j git commit: QPID-8210: [Broker-J] Make field QueueConsumerImpl#_queueConsumerNode volatile

QPID-8210: [Broker-J] Make field QueueConsumerImpl#_queueConsumerNode volatile

(cherry picked from commit a07e8fd80ea11f0458c0fcfe4bc7a0ec31b4a7bb)


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/c5bf4260
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/c5bf4260
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/c5bf4260

Branch: refs/heads/7.0.x
Commit: c5bf4260a0da733a048b9949ca0ccaf6f9bae158
Parents: ca118c9
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:40:32 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/c5bf4260/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 0972a1a..0c8670e 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