svn commit: r1422959 - in /camel/branches/camel-2.10.x: ./ components/camel-netty/src/main/java/org/apache/camel/component/netty/ components/camel-netty/src/test/java/org/apache/camel/component/netty/

[davsclaus]

Author: davsclaus
Date: Mon Dec 17 14:57:31 2012
New Revision: 1422959

URL: http://svn.apache.org/viewvc?rev=1422959&view=rev
Log:
CAMEL-5886: Added option backlog to camel-netty.

Added:
    
camel/branches/camel-2.10.x/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyBacklogTest.java
      - copied unchanged from r1422957, 
camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyBacklogTest.java
Modified:
    camel/branches/camel-2.10.x/   (props changed)
    
camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
    
camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java

Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
  Merged /camel/trunk:r1422957

Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.

Modified: 
camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
URL: 
http://svn.apache.org/viewvc/camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java?rev=1422959&r1=1422958&r2=1422959&view=diff
==============================================================================
--- 
camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
 (original)
+++ 
camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
 Mon Dec 17 14:57:31 2012
@@ -82,6 +82,7 @@ public class NettyConfiguration implemen
     private int producerPoolMinIdle;
     private int producerPoolMaxIdle = 100;
     private long producerPoolMinEvictableIdle = 5 * 60 * 1000L;
+    private int backlog;
     
     /**
      * Returns a copy of this configuration
@@ -573,6 +574,14 @@ public class NettyConfiguration implemen
         this.producerPoolMinEvictableIdle = producerPoolMinEvictableIdle;
     }
 
+    public int getBacklog() {
+        return backlog;
+    }
+
+    public void setBacklog(int backlog) {
+        this.backlog = backlog;
+    }
+
     private static <T> void addToHandlersList(List<T> configured, List<T> 
handlers, Class<T> handlerType) {
         if (handlers != null) {
             for (int x = 0; x < handlers.size(); x++) {

Modified: 
camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java
URL: 
http://svn.apache.org/viewvc/camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java?rev=1422959&r1=1422958&r2=1422959&view=diff
==============================================================================
--- 
camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java
 (original)
+++ 
camel/branches/camel-2.10.x/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConsumer.java
 Mon Dec 17 14:57:31 2012
@@ -182,6 +182,13 @@ public class NettyConsumer extends Defau
         serverBootstrap.setOption("reuseAddress", 
configuration.isReuseAddress());
         serverBootstrap.setOption("child.reuseAddress", 
configuration.isReuseAddress());
         serverBootstrap.setOption("child.connectTimeoutMillis", 
configuration.getConnectTimeout());
+        if (configuration.getBacklog() > 0) {
+            serverBootstrap.setOption("backlog", configuration.getBacklog());
+        }
+
+        if (log.isDebugEnabled()) {
+            log.debug("Created ServerBootstrap {} with options: {}", 
serverBootstrap, serverBootstrap.getOptions());
+        }
 
         // set the pipeline factory, which creates the pipeline for each newly 
created channels
         serverBootstrap.setPipelineFactory(pipelineFactory);
@@ -212,6 +219,13 @@ public class NettyConsumer extends Defau
             
connectionlessServerBootstrap.setOption("receiveBufferSizePredictorFactory",
                 new 
FixedReceiveBufferSizePredictorFactory(configuration.getReceiveBufferSizePredictor()));
         }
+        if (configuration.getBacklog() > 0) {
+            serverBootstrap.setOption("backlog", configuration.getBacklog());
+        }
+
+        if (log.isDebugEnabled()) {
+            log.debug("Created ConnectionlessBootstrap {} with options: {}", 
connectionlessServerBootstrap, connectionlessServerBootstrap.getOptions());
+        }
 
         // set the pipeline factory, which creates the pipeline for each newly 
created channels
         connectionlessServerBootstrap.setPipelineFactory(pipelineFactory);