Author: chirino
Date: Fri Nov 26 14:31:01 2010
New Revision: 1039377

URL: http://svn.apache.org/viewvc?rev=1039377&view=rev
Log:
Use a high priority queue for the broker and virtual host so that connection events are processed quicker.

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

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala?rev=1039377&r1=1039376&r2=1039377&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala Fri Nov 26 14:31:01 2010
@@ -172,7 +172,7 @@ class Broker() extends BaseService with 
 
   var connectors: List[Connector] = Nil
 
-  val dispatchQueue = createQueue("broker");
+  val dispatchQueue = getGlobalQueue(DispatchPriority.HIGH).createQueue("broker");
   if( STICK_ON_THREAD_QUEUES ) {
     dispatchQueue.setTargetQueue(Dispatch.getRandomThreadQueue)
   }

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/VirtualHost.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/VirtualHost.scala?rev=1039377&r1=1039376&r2=1039377&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/VirtualHost.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/VirtualHost.scala Fri Nov 26 14:31:01 2010
@@ -79,7 +79,7 @@ class VirtualHost(val broker: Broker, va
   import VirtualHost._
   
   override protected def log = VirtualHost
-  override val dispatchQueue:DispatchQueue = org.fusesource.hawtdispatch.createQueue("virtual-host");
+  override val dispatchQueue:DispatchQueue = getGlobalQueue(DispatchPriority.HIGH).createQueue("virtual-host");
 
   var config:VirtualHostDTO = _
   val router = new Router(this)