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:47 UTC
[09/10] camel git commit: fix restlet producer to use maxConnections
property - null check
fix restlet producer to use maxConnections property - null check
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/fc844aff
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fc844aff
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fc844aff
Branch: refs/heads/camel-2.17.x
Commit: fc844aff4c451bc9aa35f78c0bccf865948a2377
Parents: ac86e69
Author: John Moon <jo...@transamerica.com>
Authored: Mon Aug 22 10:34:25 2016 -0400
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Aug 22 18:05:54 2016 +0200
----------------------------------------------------------------------
.../org/apache/camel/component/restlet/RestletProducer.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/fc844aff/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 0a1a5b4..10a2a93 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
@@ -52,8 +52,12 @@ public class RestletProducer extends DefaultAsyncProducer {
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()));
+ if(component.getMaxConnectionsPerHost() != null && component.getMaxConnectionsPerHost() > 0) {
+ client.getContext().getParameters().add("maxConnectionsPerHost", String.valueOf(component.getMaxConnectionsPerHost()));
+ }
+ if(component.getMaxTotalConnections() != null && component.getMaxTotalConnections() > 0) {
+ client.getContext().getParameters().add("maxTotalConnections", String.valueOf(component.getMaxTotalConnections()));
+ }
}