Repository: qpid-broker-j Updated Branches: refs/heads/7.0.x 1194b6529 -> c5bf4260a
QPID-8210: [Broker-J] Set queue consumer node before adding consumer into queue consumer manager (cherry picked from commit 0c4e41829d3f97eaa171fd1276e85e1685021cfc) 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/ca118c93 Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/ca118c93 Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/ca118c93 Branch: refs/heads/7.0.x Commit: ca118c933e4ad74375d056f694fbbb367cfa33a6 Parents: 1194b65 Author: Alex Rudyy <oru...@apache.org> Authored: Mon Jun 18 17:51:47 2018 +0100 Committer: Alex Rudyy <oru...@apache.org> Committed: Tue Jun 19 17:40:18 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/ca118c93/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-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
