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 <davscl...@apache.org> Authored: Mon Oct 7 18:46:50 2013 +0200 Committer: Claus Ibsen <davscl...@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;
