From a1e410f761253564f599ff6c2b6a42c1e19398ae Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Mon, 10 Apr 2006 12:19:24 +0000 Subject: [PATCH] another memory leak fixed git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392929 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/activemq/advisory/AdvisoryBroker.java | 2 ++ 1 file changed, 2 insertions(+) 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 {