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/d0d6560d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d0d6560d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d0d6560d Branch: refs/heads/master Commit: d0d6560dab9a16b2a04c2977befabf08f124b1de Parents: 3969f8a 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:46:50 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/d0d6560d/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;
