activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1328429 - /activemq/activemq-apollo/trunk/apollo-web/src/main/scala/org/apache/activemq/apollo/web/resources/BrokerResource.scala
Date Fri, 20 Apr 2012 16:02:37 GMT
Author: chirino
Date: Fri Apr 20 16:02:36 2012
New Revision: 1328429

URL: http://svn.apache.org/viewvc?rev=1328429&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-web/src/main/scala/org/apache/activemq/apollo/web/resources/BrokerResource.scala

Modified: activemq/activemq-apollo/trunk/apollo-web/src/main/scala/org/apache/activemq/apollo/web/resources/BrokerResource.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-web/src/main/scala/org/apache/activemq/apollo/web/resources/BrokerResource.scala?rev=1328429&r1=1328428&r2=1328429&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-web/src/main/scala/org/apache/activemq/apollo/web/resources/BrokerResource.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-web/src/main/scala/org/apache/activemq/apollo/web/resources/BrokerResource.scala
Fri Apr 20 16:02:36 2012
@@ -563,7 +563,9 @@ class BrokerResource() extends Resource 
       val router: LocalRouter = host
       val node = router.local_queue_domain.destination_by_id.get(name).getOrElse(result(NOT_FOUND))
       admining(node) {
-        router._destroy_queue(node)
+        host.dispatch_queue {
+          router._destroy_queue(node)
+        }
       }
     }
   }
@@ -614,7 +616,9 @@ class BrokerResource() extends Resource 
       val router: LocalRouter = host
       val node = router.local_dsub_domain.destination_by_id.get(name).getOrElse(result(NOT_FOUND))
       admining(node) {
-        router._destroy_queue(node)
+        host.dispatch_queue {
+          router._destroy_queue(node)
+        }
       }
     }
   }



Mime
View raw message