From ae5300b1904fdadbd7e5817f849f3fbc5df3a943 Mon Sep 17 00:00:00 2001 From: Bosanac Dejan Date: Thu, 17 Jun 2010 14:56:23 +0000 Subject: [PATCH] https://issues.apache.org/activemq/browse/AMQ-2782 - removing temp destinations over the network git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@955621 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/activemq/advisory/AdvisoryBroker.java | 2 +- 1 file changed, 1 insertion(+), 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 6b2e5fb989..2b5ad65d8a 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 @@ -241,7 +241,7 @@ public class AdvisoryBroker extends BrokerFilter { if (!AdvisorySupport.isAdvisoryTopic(dest)) { ActiveMQTopic topic = AdvisorySupport.getConsumerAdvisoryTopic(dest); consumers.remove(info.getConsumerId()); - if (!dest.isTemporary() || destinations.contains(dest)) { + if (!dest.isTemporary() || destinations.containsKey(dest)) { fireConsumerAdvisory(context,dest, topic, info.createRemoveCommand()); } }