You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2008/03/13 21:31:34 UTC

svn commit: r636868 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java

Author: rajdavies
Date: Thu Mar 13 13:31:32 2008
New Revision: 636868

URL: http://svn.apache.org/viewvc?rev=636868&view=rev
Log:
too many advisories flying about

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java?rev=636868&r1=636867&r2=636868&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java Thu Mar 13 13:31:32 2008
@@ -84,7 +84,7 @@
         // 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 @@
                 }
             }
         }
-        consumers.put(info.getConsumerId(), info);
         return answer;
     }