diff options
Diffstat (limited to 'java/broker/src/main')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java | 8 | ||||
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java | 9 |
2 files changed, 9 insertions, 8 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java b/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java index b24a326ed3..7393f27ab4 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java +++ b/java/broker/src/main/java/org/apache/qpid/server/binding/BindingFactory.java @@ -204,14 +204,6 @@ public class BindingFactory getConfigStore().addConfiguredObject(b); b.logCreation(); - //Reconfigure the queue for to reflect this new binding. - ConfigurationPlugin config = queue.getVirtualHost().getConfiguration().getQueueConfiguration(queue); - - if (config != null) - { - // Reconfigure with new config. - queue.configure(config); - } return true; } else diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java b/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java index 451d59b2e9..c4567b2e8b 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java +++ b/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java @@ -503,6 +503,15 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener break; } } + + //Reconfigure the queue for to reflect this new binding. + ConfigurationPlugin config = getVirtualHost().getConfiguration().getQueueConfiguration(this); + + if (config != null) + { + // Reconfigure with new config. + configure(config); + } } public int getBindingCountHigh() |