Repository: qpid-broker-j Updated Branches: refs/heads/6.1.x 94dd1bb27 -> 11b691ba1
QPID-7853: [Broker-J] Avoid possibility that a message is enqueue twice to the same queue. 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/11b691ba Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/11b691ba Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/11b691ba Branch: refs/heads/6.1.x Commit: 11b691ba1699b063b3e3cbbcaa62b5b7b48aa468 Parents: 94dd1bb Author: Keith Wall <kw...@apache.org> Authored: Wed Nov 8 10:56:34 2017 +0000 Committer: Keith Wall <kw...@apache.org> Committed: Wed Nov 8 10:56:34 2017 +0000 ---------------------------------------------------------------------- .../main/java/org/apache/qpid/server/exchange/AbstractExchange.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/11b691ba/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java ---------------------------------------------------------------------- diff --git a/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java b/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java index 4b37cce..fa3b856 100644 --- a/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java +++ b/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java @@ -493,6 +493,7 @@ public abstract class AbstractExchange<T extends AbstractExchange<T>> } } baseQueues = uniqueQueues.toArray(new BaseQueue[uniqueQueues.size()]); + queues = uniqueQueues; } else { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
