svn commit: r1182369 - in /camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty: NettyConfiguration.java NettyConsumer.java

[ningjiang]

Author: ningjiang
Date: Wed Oct 12 13:54:32 2011
New Revision: 1182369

URL: http://svn.apache.org/viewvc?rev=1182369&view=rev
Log:
CAMEL-4531 Added the option of workCount

Modified:
    
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
    
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java

Modified: 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java?rev=1182369&r1=1182368&r2=1182369&view=diff
==============================================================================
--- 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
 (original)
+++ 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
 Wed Oct 12 13:54:32 2011
@@ -68,6 +68,7 @@ public class NettyConfiguration implemen
     private long receiveBufferSize = 65536;
     private int corePoolSize = 10;
     private int maxPoolSize = 100;
+    private int workerCount;
     private String keyStoreFormat;
     private String securityProvider;
     private boolean disconnect;
@@ -483,5 +484,13 @@ public class NettyConfiguration implemen
     public ServerPipelineFactory getServerPipelineFactory() {
         return serverPipelineFactory;
     }
+    
+    public int getWorkerCount() {
+        return workerCount;
+    }
+
+    public void setWorkerCount(int workerCount) {
+        this.workerCount = workerCount;
+    }
 
 }

Modified: 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java?rev=1182369&r1=1182368&r2=1182369&view=diff
==============================================================================
--- 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java
 (original)
+++ 
camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java
 Wed Oct 12 13:54:32 2011
@@ -148,7 +148,12 @@ public class NettyConsumer extends Defau
         ExecutorService workerExecutor = 
context.getExecutorServiceManager().newThreadPool(this, "NettyTCPWorker",
                 configuration.getCorePoolSize(), 
configuration.getMaxPoolSize());
 
-        channelFactory = new NioServerSocketChannelFactory(bossExecutor, 
workerExecutor);
+        if (configuration.getWorkerCount() == 0) {
+            channelFactory = new NioServerSocketChannelFactory(bossExecutor, 
workerExecutor);
+        } else {
+            channelFactory = new NioServerSocketChannelFactory(bossExecutor, 
workerExecutor,
+                                                               
configuration.getWorkerCount());
+        }
         serverBootstrap = new ServerBootstrap(channelFactory);
         if (configuration.getServerPipelineFactory() != null) {
             configuration.getServerPipelineFactory().setConsumer(this);