activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1329217 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
Date Mon, 23 Apr 2012 12:49:22 GMT
Author: chirino
Date: Mon Apr 23 12:49:22 2012
New Revision: 1329217

URL: http://svn.apache.org/viewvc?rev=1329217&view=rev
Log:
Fixes APLO-192 : "java.lang.AssertionError: Dispatch queue 'virtual-host' was not executing"
occurs when queue or dsub is deleted via web admin

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

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala?rev=1329217&r1=1329216&r2=1329217&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
Mon Apr 23 12:49:22 2012
@@ -411,7 +411,9 @@ class Queue(val router: LocalRouter, val
         dispatch_queue.after(auto_delete_after, TimeUnit.SECONDS) {
           // Have we been idle that whole time?
           if( idled_at == idled_at_start ) {
-            router._destroy_queue(this)
+            virtual_host.dispatch_queue {
+              router._destroy_queue(this)
+            }
           }
         }
       }



Mime
View raw message