You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2012/04/20 18:02:37 UTC
svn commit: r1328429 -
/activemq/activemq-apollo/trunk/apollo-web/src/main/scala/org/apache/activemq/apollo/web/resources/BrokerResource.scala
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)
+ }
}
}
}