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 ) {
