commit 0c4e41829d3f97eaa171fd1276e85e1685021cfc
author Alex Rudyy <orudyy@apache.org> Mon Jun 18 17:51:47 2018 +0100
committer Alex Rudyy <orudyy@apache.org> Mon Jun 18 18:20:52 2018 +0100
tree d6859a209d02aabfae31dc72f9b67f6e98d1e06e
parent ec957a270c2218e962c8e723dbd77e5657e7e0ff

QPID-8210: [Broker-J] Set queue consumer node before adding consumer into queue consumer manager

broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerManagerImpl.java

diff --git a/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerManagerImpl.java b/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerManagerImpl.java
index 5f94eb7..d1fd058 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerManagerImpl.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerManagerImpl.java
@@ -74,9 +74,8 @@
     public void addConsumer(final QueueConsumer<?,?> consumer)
     {
         QueueConsumerNode node = new QueueConsumerNode(this, consumer);
-        addToAll(node);
-
         consumer.setQueueConsumerNode(node);
+        addToAll(node);
         if (consumer.isNotifyWorkDesired())
         {
             if (consumer.acquires())