diff options
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java index 1fa86cf33c..e34646d66f 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java @@ -676,6 +676,8 @@ public abstract class AbstractExchange<T extends AbstractExchange<T>> } queue.addBinding(b); + childAdded(b); + doAddBinding(b); return true; @@ -851,7 +853,6 @@ public abstract class AbstractExchange<T extends AbstractExchange<T>> { addBinding(bindingKey, (AMQQueue) queue, bindingArguments); final BindingImpl binding = getBinding(bindingKey, (AMQQueue) queue); - childAdded(binding); return binding; } |