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:41 UTC
[03/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/593c19af
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/593c19af
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/593c19af
Branch: refs/heads/master
Commit: 593c19af3209481cb5fd032117ce4b2b1d516ba4
Parents: eba74e3
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:04:25 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/593c19af/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()));
+ }
}