activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r636868 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java
Date Thu, 13 Mar 2008 20:31:34 GMT
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;
     }
 



Mime
View raw message