commit a07e8fd80ea11f0458c0fcfe4bc7a0ec31b4a7bb
author Alex Rudyy <orudyy@apache.org> Tue Jun 19 17:38:29 2018 +0100
committer Alex Rudyy <orudyy@apache.org> Tue Jun 19 17:38:29 2018 +0100
tree 7a36dfbf0869c0dd3c347628fc9beea24563e4da
parent 0c4e41829d3f97eaa171fd1276e85e1685021cfc

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

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 @@
 
     private final String _linkName;
 
-    private QueueConsumerNode _queueConsumerNode;
+    private volatile QueueConsumerNode _queueConsumerNode;
 
     QueueConsumerImpl(final AbstractQueue<?> queue,
                       T target,