diff options
Diffstat (limited to 'qpid/java')
3 files changed, 2 insertions, 10 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/binding/BindingImpl.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/binding/BindingImpl.java index 0bba5c7967..9fdae72188 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/binding/BindingImpl.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/binding/BindingImpl.java @@ -94,7 +94,6 @@ public class BindingImpl //Perform ACLs queue.getVirtualHost().getSecurityManager().authoriseCreateBinding(this); - _queue.bindingCreated(this); _logSubject = new BindingLogSubject(_bindingKey,exchange,queue); getEventLogger().message(_logSubject, BindingMessages.CREATED(String.valueOf(getArguments()), getArguments() != null diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AMQQueue.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AMQQueue.java index b758365039..e9c5f8206a 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AMQQueue.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AMQQueue.java @@ -225,6 +225,4 @@ public interface AMQQueue<X extends AMQQueue<X>> long getUnacknowledgedMessages(); - - void bindingCreated(Binding<BindingImpl> binding); } diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java index 8e791cd326..ab3da6224e 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java @@ -958,11 +958,13 @@ public abstract class AbstractQueue break; } } + childAdded(binding); } public void removeBinding(final BindingImpl binding) { _bindings.remove(binding); + childRemoved(binding); } public Collection<BindingImpl> getBindings() @@ -3083,13 +3085,6 @@ public abstract class AbstractQueue } } - @Override - public void bindingCreated(final Binding<BindingImpl> binding) - { - childAdded(binding); - binding.addChangeListener(_deletedChildListener); - } - private class DeletedChildListener implements ConfigurationChangeListener { @Override |