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 2011/06/09 03:13:01 UTC
svn commit: r1133622 -
/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/jetty/JettyWebServer.scala
Author: chirino
Date: Thu Jun 9 01:13:00 2011
New Revision: 1133622
URL: http://svn.apache.org/viewvc?rev=1133622&view=rev
Log:
Configure the thread pool on the server.
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/jetty/JettyWebServer.scala
Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/jetty/JettyWebServer.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/jetty/JettyWebServer.scala?rev=1133622&r1=1133621&r2=1133622&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/jetty/JettyWebServer.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/jetty/JettyWebServer.scala Thu Jun 9 01:13:00 2011
@@ -208,8 +208,6 @@ class JettyWebServer(val broker:Broker)
connector
}
-
- connector.setThreadPool(new ExecutorThreadPool(Broker.BLOCKABLE_THREAD_POOL))
connector.setHost(host)
connector.setPort(port)
connectors.put(connector_id, connector)
@@ -235,6 +233,7 @@ class JettyWebServer(val broker:Broker)
server = new Server
server.setHandler(context_list)
server.setConnectors(connectors.values.toArray)
+ server.setThreadPool(new ExecutorThreadPool(Broker.BLOCKABLE_THREAD_POOL))
server.start
for( connector <- connectors.values ; prefix <- contexts.keys ) {