camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject git commit: CAMEL-7082 Supporting to set more work thread in camel-restlet component
Date Thu, 19 Dec 2013 09:10:30 GMT
Updated Branches:
  refs/heads/master 870070977 -> fdb19f5d1


CAMEL-7082 Supporting to set more work thread in camel-restlet component


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/fdb19f5d
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fdb19f5d
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fdb19f5d

Branch: refs/heads/master
Commit: fdb19f5d1d173ce95dff9a82a9aec0157a3f870a
Parents: 8700709
Author: Willem Jiang <willem.jiang@gmail.com>
Authored: Thu Dec 19 17:09:24 2013 +0800
Committer: Willem Jiang <willem.jiang@gmail.com>
Committed: Thu Dec 19 17:09:57 2013 +0800

----------------------------------------------------------------------
 .../component/restlet/RestletComponent.java     | 25 ++++++++++++++++++++
 1 file changed, 25 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/fdb19f5d/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java
b/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java
index 720be3e..6eae3df 100644
--- a/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java
+++ b/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java
@@ -57,9 +57,11 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
     private Integer inboundBufferSize;
     private Integer minThreads;
     private Integer maxThreads;
+    private Integer lowThreads;
     private Integer maxConnectionsPerHost;
     private Integer maxTotalConnections;
     private Integer outboundBufferSize;
+    private Integer maxQueued;
     private Boolean persistingConnections;
     private Boolean pipeliningConnections;
     private Integer threadMaxIdleTimeMs;
@@ -237,6 +239,12 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
                 if (getMaxThreads() != null) {
                     params.add("maxThreads", getMaxThreads().toString());
                 }
+                if (getLowThreads() != null) {
+                    params.add("lowThreads", getLowThreads().toString());
+                }
+                if (getMaxQueued() != null) {
+                    params.add("maxQueued", getMaxQueued().toString());
+                }
                 if (getMaxConnectionsPerHost() != null) {
                     params.add("maxConnectionsPerHost", getMaxConnectionsPerHost().toString());
                 }
@@ -261,6 +269,7 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
                 if (getReuseAddress() != null) {
                     params.add("reuseAddress", getReuseAddress().toString());
                 }
+                
                 LOG.debug("Setting parameters: {} to server: {}", params, server);
                 server.getContext().setParameters(params);
 
@@ -372,6 +381,14 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
     public void setMaxThreads(Integer maxThreads) {
         this.maxThreads = maxThreads;
     }
+    
+    public Integer getLowThreads() {
+        return lowThreads;
+    }
+
+    public void setLowThreads(Integer lowThreads) {
+        this.lowThreads = lowThreads;
+    }
 
     public Integer getMaxTotalConnections() {
         return maxTotalConnections;
@@ -436,4 +453,12 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
     public void setReuseAddress(Boolean reuseAddress) {
         this.reuseAddress = reuseAddress;
     }
+
+    public Integer getMaxQueued() {
+        return maxQueued;
+    }
+
+    public void setMaxQueued(Integer maxQueued) {
+        this.maxQueued = maxQueued;
+    }
 }


Mime
View raw message