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 2016/08/22 16:06:43 UTC
[05/10] camel git commit: fix restlet producer to use maxConnections
property
fix restlet producer to use maxConnections property
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/eba74e36
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/eba74e36
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/eba74e36
Branch: refs/heads/master
Commit: eba74e3682de088d4f92eedabbd81fe61728b847
Parents: 1dc122c
Author: John Moon <jo...@transamerica.com>
Authored: Mon Aug 22 09:37:10 2016 -0400
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Aug 22 18:04:25 2016 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/component/restlet/RestletProducer.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/eba74e36/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletProducer.java b/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletProducer.java
index 6d53fa5..0a1a5b4 100644
--- a/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletProducer.java
+++ b/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletProducer.java
@@ -51,6 +51,10 @@ public class RestletProducer extends DefaultAsyncProducer {
client.setContext(new Context());
client.getContext().getParameters().add("socketTimeout", String.valueOf(endpoint.getSocketTimeout()));
client.getContext().getParameters().add("socketConnectTimeoutMs", String.valueOf(endpoint.getSocketTimeout()));
+ RestletComponent component = (RestletComponent)endpoint.getComponent();
+ client.getContext().getParameters().add("maxConnectionsPerHost", String.valueOf(component.getMaxConnectionsPerHost()));
+ client.getContext().getParameters().add("maxTotalConnections", String.valueOf(component.getMaxTotalConnections()));
+
}
@Override