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 2010/07/07 06:14:45 UTC
svn commit: r961184 -
/activemq/sandbox/activemq-apollo-actor/activemq-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
Author: chirino
Date: Wed Jul 7 04:14:45 2010
New Revision: 961184
URL: http://svn.apache.org/viewvc?rev=961184&view=rev
Log:
do the each in the context of the dispatchQueue
Modified:
activemq/sandbox/activemq-apollo-actor/activemq-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
Modified: activemq/sandbox/activemq-apollo-actor/activemq-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala?rev=961184&r1=961183&r2=961184&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala Wed Jul 7 04:14:45 2010
@@ -200,12 +200,12 @@ class Router(val host:VirtualHost) exten
} >>: dispatchQueue
- def each(proc:(Destination, DestinationNode)=>Unit) = {
+ def each(proc:(Destination, DestinationNode)=>Unit) = dispatchQueue {
import JavaConversions._
for( (destination, node) <- destinations ) {
proc(destination, node)
}
- }
+ }
}