activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1373689 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala
Date Thu, 16 Aug 2012 02:00:13 GMT
Author: chirino
Date: Thu Aug 16 02:00:13 2012
New Revision: 1373689

URL: http://svn.apache.org/viewvc?rev=1373689&view=rev
Log:
Always set the blocking executors on transports.

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

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala?rev=1373689&r1=1373688&r2=1373689&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala
Thu Aug 16 02:00:13 2012
@@ -232,6 +232,7 @@ class AcceptingConnector(val broker:Brok
     protocol = ProtocolFactory.get(config.protocol.getOrElse("any")).get
     transport_server = TransportFactory.bind( config.bind )
     transport_server.setDispatchQueue(dispatch_queue)
+    transport_server.setBlockingExecutor(Broker.BLOCKABLE_THREAD_POOL);
     transport_server.setTransportServerListener(BrokerAcceptListener)
 
     transport_server match {
@@ -242,7 +243,6 @@ class AcceptingConnector(val broker:Brok
 
     transport_server match {
       case transport_server:SslTransportServer =>
-        transport_server.setBlockingExecutor(Broker.BLOCKABLE_THREAD_POOL);
         if( broker.key_storage!=null ) {
           transport_server.setTrustManagers(broker.key_storage.create_trust_managers)
           transport_server.setKeyManagers(broker.key_storage.create_key_managers)



Mime
View raw message