From 320f80263ebfa49ceb5136f7dce228bb0ca5d9ff Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Thu, 13 Mar 2008 20:31:32 +0000 Subject: [PATCH] too many advisories flying about git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636868 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/activemq/advisory/AdvisoryBroker.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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 485e1aa9b8..bc7937dd82 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 @@ -84,7 +84,7 @@ public class AdvisoryBroker extends BrokerFilter { // Don't advise advisory topics. if (!AdvisorySupport.isAdvisoryTopic(info.getDestination())) { ActiveMQTopic topic = AdvisorySupport.getConsumerAdvisoryTopic(info.getDestination()); - //consumers.put(info.getConsumerId(), info); + consumers.put(info.getConsumerId(), info); fireConsumerAdvisory(context,info.getDestination(), topic, info); } else { // We need to replay all the previously collected state objects @@ -128,7 +128,6 @@ public class AdvisoryBroker extends BrokerFilter { } } } - consumers.put(info.getConsumerId(), info); return answer; }