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

[rajdavies]

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;
     }