activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1422242 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Subscription.scala
Date Sat, 15 Dec 2012 13:05:56 GMT
Author: chirino
Date: Sat Dec 15 13:05:55 2012
New Revision: 1422242

URL: http://svn.apache.org/viewvc?rev=1422242&view=rev
Log:
Make sure we take subscriptions out of the message group hash ring once  they are closed.

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

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Subscription.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Subscription.scala?rev=1422242&r1=1422241&r2=1422242&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Subscription.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Subscription.scala
Sat Dec 15 13:05:55 2012
@@ -208,6 +208,12 @@ class Subscription(val queue:Queue, val 
 
       queue.exclusive_subscriptions = queue.exclusive_subscriptions.filterNot( _ == this
)
       queue.all_subscriptions -= consumer
+      if( !consumer.browser && queue._message_group_buckets != null ) {
+        queue._message_group_buckets.remove(GroupBucket(this))
+        if( queue._message_group_buckets.getNodes.isEmpty ) {
+          queue._message_group_buckets = null
+        }
+      }
 
       session.refiller = NOOP
       session.close



Mime
View raw message