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/f1f69f00 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f1f69f00 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f1f69f00 Branch: refs/heads/camel-2.12.x Commit: f1f69f00cd8a937bfd01cfd057a3e6c1138f6f97 Parents: d02dbb3 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:15 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/f1f69f00/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 333f5f9..e22458c 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;
