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 920a41c0b9..39af589ce8 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
@@ -174,6 +174,8 @@ public class AdvisoryBroker extends BrokerFilter {
         next.removeDestinationInfo(context, info);
         ActiveMQTopic topic = AdvisorySupport.getDestinationAdvisoryTopic(info.getDestination());
         fireAdvisory(context, topic, info);
+        next.removeDestination(context, AdvisorySupport.getConsumerAdvisoryTopic(info.getDestination()), 0); 
+        next.removeDestination(context, AdvisorySupport.getProducerAdvisoryTopic(info.getDestination()), 0); 
     }
 
     public void removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error) throws Exception {