You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2011/10/12 15:54:32 UTC
svn commit: r1182369 - in /camel/trunk/components/camel-netty/src/main/java/org/apache/camel/component/netty: NettyConfiguration.java NettyConsumer.java

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