activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1416615 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Topic.scala
Date Mon, 03 Dec 2012 18:18:48 GMT
Author: chirino
Date: Mon Dec  3 18:18:47 2012
New Revision: 1416615

URL: http://svn.apache.org/viewvc?rev=1416615&view=rev
Log:
Make sure we unbind producers from consumers when the producers disconnect.

Modified:
    activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Topic.scala

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Topic.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Topic.scala?rev=1416615&r1=1416614&r2=1416615&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Topic.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Topic.scala
Mon Dec  3 18:18:47 2012
@@ -563,6 +563,11 @@ class Topic(val router:LocalRouter, val 
     for(link <- producers.remove(producer) ) {
       add_enqueue_counters(topic_metrics, link)
     }
+    var targets:List[DeliveryConsumer] = producer_tracker :: consumers.values.toList
+    if( topic_queue !=null ) {
+      targets ::= topic_queue
+    }
+    producer.unbind(targets)
     check_idle
   }
 



Mime
View raw message