qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From oru...@apache.org
Subject qpid-broker-j git commit: QPID-8210: [Broker-J] Set queue consumer node before adding consumer into queue consumer manager
Date Mon, 18 Jun 2018 17:22:41 GMT
Repository: qpid-broker-j
Updated Branches:
  refs/heads/master ec957a270 -> 0c4e41829


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


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

Branch: refs/heads/master
Commit: 0c4e41829d3f97eaa171fd1276e85e1685021cfc
Parents: ec957a2
Author: Alex Rudyy <orudyy@apache.org>
Authored: Mon Jun 18 17:51:47 2018 +0100
Committer: Alex Rudyy <orudyy@apache.org>
Committed: Mon Jun 18 18:20:52 2018 +0100

----------------------------------------------------------------------
 .../org/apache/qpid/server/queue/QueueConsumerManagerImpl.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/0c4e4182/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 class QueueConsumerManagerImpl implements QueueConsumerManager
     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())


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message