camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [6/6] git commit: CAMEL-6825: client min/max threads uri options is internal in camel-jetty.
Date Mon, 07 Oct 2013 16:47:57 GMT
CAMEL-6825: client min/max threads uri options is internal in camel-jetty.


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

Branch: refs/heads/camel-2.11.x
Commit: 117257096b67ac5a9b54015ae05316834ca9a22a
Parents: 0140822
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Mon Oct 7 18:46:50 2013 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Mon Oct 7 18:47:36 2013 +0200

----------------------------------------------------------------------
 .../apache/camel/component/jetty/JettyHttpComponent.java  | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/11725709/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
index 7c6a9bb..33c21fd 100644
--- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
+++ b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
@@ -159,7 +159,9 @@ public class JettyHttpComponent extends HttpComponent {
         String proxyHost = getAndRemoveParameter(parameters, "proxyHost", String.class, getProxyHost());
         Integer proxyPort = getAndRemoveParameter(parameters, "proxyPort", Integer.class,
getProxyPort());
         Integer responseBufferSize = getAndRemoveParameter(parameters, "responseBufferSize",
Integer.class, getResponseBufferSize());
-        
+        Integer httpClientMinThreads = getAndRemoveParameter(parameters, "httpClientMinThreads",
Integer.class, this.httpClientMinThreads);
+        Integer httpClientMaxThreads = getAndRemoveParameter(parameters, "httpClientMaxThreads",
Integer.class, this.httpClientMaxThreads);
+
         // extract httpClient. parameters
         Map<String, Object> httpClientParameters = IntrospectionSupport.extractProperties(parameters,
"httpClient.");
 
@@ -255,6 +257,12 @@ public class JettyHttpComponent extends HttpComponent {
         if (responseBufferSize != null) {
             endpoint.setResponseBufferSize(responseBufferSize);
         }
+        if (httpClientMinThreads != null) {
+            endpoint.setHttpClientMinThreads(httpClientMinThreads);
+        }
+        if (httpClientMaxThreads != null) {
+            endpoint.setHttpClientMaxThreads(httpClientMaxThreads);
+        }
 
         setProperties(endpoint, parameters);
         return endpoint;


Mime
View raw message