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)
