You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2013/10/07 18:47:57 UTC
[6/6] git commit: CAMEL-6825: client min/max threads uri options is
internal in camel-jetty.
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 <da...@apache.org>
Authored: Mon Oct 7 18:46:50 2013 +0200
Committer: Claus Ibsen <da...@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;