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/11/26 15:31:01 UTC
svn commit: r1039377 - in
/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker:
Broker.scala VirtualHost.scala
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)