svn commit: r1021991 - /camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java

[ningjiang]

Author: ningjiang
Date: Wed Oct 13 04:00:18 2010
New Revision: 1021991

URL: http://svn.apache.org/viewvc?rev=1021991&view=rev
Log:
CAMEL-3230 Changed the MinaComponent to use the defaultThreadPool instread of 
cachedThreadPool

Modified:
    
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java

Modified: 
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java?rev=1021991&r1=1021990&r2=1021991&view=diff
==============================================================================
--- 
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
 (original)
+++ 
camel/trunk/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaComponent.java
 Wed Oct 13 04:00:18 2010
@@ -165,9 +165,9 @@ public class MinaComponent extends Defau
         final int processorCount = Runtime.getRuntime().availableProcessors() 
+ 1;
 
         IoAcceptor acceptor = new SocketAcceptor(processorCount,
-                
getCamelContext().getExecutorServiceStrategy().newCachedThreadPool(this, 
"MinaSocketAcceptor"));
+                
getCamelContext().getExecutorServiceStrategy().newDefaultThreadPool(this, 
"MinaSocketAcceptor"));
         IoConnector connector = new SocketConnector(processorCount,
-                
getCamelContext().getExecutorServiceStrategy().newCachedThreadPool(this, 
"MinaSocketConnector"));
+                
getCamelContext().getExecutorServiceStrategy().newDefaultThreadPool(this, 
"MinaSocketConnector"));
         SocketAddress address = new InetSocketAddress(configuration.getHost(), 
configuration.getPort());
 
         // connector config
@@ -176,7 +176,7 @@ public class MinaComponent extends Defau
         connectorConfig.setThreadModel(ThreadModel.MANUAL);
         configureCodecFactory("MinaProducer", connectorConfig, configuration);
         connectorConfig.getFilterChain().addLast("threadPool",
-                new 
ExecutorFilter(getCamelContext().getExecutorServiceStrategy().newCachedThreadPool(this,
 "MinaThreadPool")));
+                new 
ExecutorFilter(getCamelContext().getExecutorServiceStrategy().newDefaultThreadPool(this,
 "MinaThreadPool")));
         if (minaLogger) {
             connectorConfig.getFilterChain().addLast("logger", new 
LoggingFilter());
         }
@@ -193,7 +193,7 @@ public class MinaComponent extends Defau
         acceptorConfig.setReuseAddress(true);
         acceptorConfig.setDisconnectOnUnbind(true);
         acceptorConfig.getFilterChain().addLast("threadPool",
-                new 
ExecutorFilter(getCamelContext().getExecutorServiceStrategy().newCachedThreadPool(this,
 "MinaThreadPool")));
+                new 
ExecutorFilter(getCamelContext().getExecutorServiceStrategy().newDefaultThreadPool(this,
 "MinaThreadPool")));
         if (minaLogger) {
             acceptorConfig.getFilterChain().addLast("logger", new 
LoggingFilter());
         }
@@ -261,8 +261,8 @@ public class MinaComponent extends Defau
         boolean sync = configuration.isSync();
         List<IoFilter> filters = configuration.getFilters();
 
-        IoAcceptor acceptor = new 
DatagramAcceptor(getCamelContext().getExecutorServiceStrategy().newCachedThreadPool(this,
 "MinaDatagramAcceptor"));
-        IoConnector connector = new 
DatagramConnector(getCamelContext().getExecutorServiceStrategy().newCachedThreadPool(this,
 "MinaDatagramConnector"));
+        IoAcceptor acceptor = new 
DatagramAcceptor(getCamelContext().getExecutorServiceStrategy().newDefaultThreadPool(this,
 "MinaDatagramAcceptor"));
+        IoConnector connector = new 
DatagramConnector(getCamelContext().getExecutorServiceStrategy().newDefaultThreadPool(this,
 "MinaDatagramConnector"));
         SocketAddress address = new InetSocketAddress(configuration.getHost(), 
configuration.getPort());
 
         if (transferExchange) {
@@ -274,7 +274,7 @@ public class MinaComponent extends Defau
         connectorConfig.setThreadModel(ThreadModel.MANUAL);
         configureDataGramCodecFactory("MinaProducer", connectorConfig, 
configuration);
         connectorConfig.getFilterChain().addLast("threadPool",
-                new 
ExecutorFilter(getCamelContext().getExecutorServiceStrategy().newCachedThreadPool(this,
 "MinaThreadPool")));
+                new 
ExecutorFilter(getCamelContext().getExecutorServiceStrategy().newDefaultThreadPool(this,
 "MinaThreadPool")));
         if (minaLogger) {
             connectorConfig.getFilterChain().addLast("logger", new 
LoggingFilter());
         }
@@ -289,7 +289,7 @@ public class MinaComponent extends Defau
         acceptorConfig.setDisconnectOnUnbind(true);
         // reuse address is default true for datagram
         acceptorConfig.getFilterChain().addLast("threadPool",
-                new 
ExecutorFilter(getCamelContext().getExecutorServiceStrategy().newCachedThreadPool(this,
 "MinaThreadPool")));
+                new 
ExecutorFilter(getCamelContext().getExecutorServiceStrategy().newDefaultThreadPool(this,
 "MinaThreadPool")));
         if (minaLogger) {
             acceptorConfig.getFilterChain().addLast("logger", new 
LoggingFilter());
         }