Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

too many advisories flying about 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636868 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-03-13 20:31:32 +00:00
parent 5fd3229c0b
commit 320f80263e
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java
View File

@ -84,7 +84,7 @@ public class AdvisoryBroker extends BrokerFilter {
// Don't advise advisory topics. // Don't advise advisory topics.
if (!AdvisorySupport.isAdvisoryTopic(info.getDestination())) { if (!AdvisorySupport.isAdvisoryTopic(info.getDestination())) {
ActiveMQTopic topic = AdvisorySupport.getConsumerAdvisoryTopic(info.getDestination()); ActiveMQTopic topic = AdvisorySupport.getConsumerAdvisoryTopic(info.getDestination());
//consumers.put(info.getConsumerId(), info); consumers.put(info.getConsumerId(), info);
fireConsumerAdvisory(context,info.getDestination(), topic, info); fireConsumerAdvisory(context,info.getDestination(), topic, info);
} else { } else {
// We need to replay all the previously collected state objects // 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; return answer;
} }