From 973147afb0de924d600f7103d5c885baa8d18772 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Sat, 8 Apr 2006 22:47:09 +0000 Subject: [PATCH] Fix for http://issues.apache.org/activemq/browse/AMQ-677 git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392623 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/activemq/advisory/AdvisoryBroker.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java b/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java index c8f47675c7..91beab9e2f 100755 --- a/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java +++ b/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java @@ -153,6 +153,7 @@ public class AdvisoryBroker extends BrokerFilter { info.setOperationType(DestinationInfo.REMOVE_OPERATION_TYPE); fireAdvisory(context, topic, info); } + next.removeDestination(context, AdvisorySupport.getConsumerAdvisoryTopic(info.getDestination()), timeout); } public void addDestinationInfo(ConnectionContext context,DestinationInfo info) throws Exception{ @@ -167,7 +168,7 @@ public class AdvisoryBroker extends BrokerFilter { public void removeDestinationInfo(ConnectionContext context,DestinationInfo info) throws Exception{ next.removeDestinationInfo(context, info); ActiveMQTopic topic = AdvisorySupport.getDestinationAdvisoryTopic(info.getDestination()); - fireAdvisory(context, topic, info); + fireAdvisory(context, topic, info); } public void removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error) throws Exception {