summaryrefslogtreecommitdiff
path: root/java/broker/src
diff options
context:
space:
mode:
Diffstat (limited to 'java/broker/src')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java9
1 files changed, 8 insertions, 1 deletions
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 489a724254..484dd5971d 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
@@ -515,7 +515,12 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener
break;
}
}
-
+
+ reconfigure();
+ }
+
+ private void reconfigure()
+ {
//Reconfigure the queue for to reflect this new binding.
ConfigurationPlugin config = getVirtualHost().getConfiguration().getQueueConfiguration(this);
@@ -539,6 +544,8 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener
public void removeBinding(final Binding binding)
{
_bindings.remove(binding);
+
+ reconfigure();
}
public List<Binding> getBindings()