CAMEL-7014 setup the client timeout of camel-restlet with thanks of Benjamin
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1e269c86 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1e269c86 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1e269c86 Branch: refs/heads/camel-2.12.x Commit: 1e269c864b3d128971f67dd548858da961c7d9a2 Parents: fa1d427 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Mon Jan 6 14:23:32 2014 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Mon Jan 6 15:43:12 2014 +0800 ---------------------------------------------------------------------- .../apache/camel/component/restlet/RestletEndpoint.java | 10 ++++++++++ .../apache/camel/component/restlet/RestletProducer.java | 3 ++- 2 files changed, 12 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/1e269c86/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java b/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java index f27787b..2caccd1 100644 --- a/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java +++ b/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletEndpoint.java @@ -39,6 +39,7 @@ public class RestletEndpoint extends DefaultEndpoint implements HeaderFilterStra private static final int DEFAULT_PORT = 80; private static final String DEFAULT_PROTOCOL = "http"; private static final String DEFAULT_HOST = "localhost"; + private static final int DEFAULT_SOCKETTIMEOUT = 30000; private Method restletMethod = Method.GET; @@ -49,6 +50,7 @@ public class RestletEndpoint extends DefaultEndpoint implements HeaderFilterStra private String protocol = DEFAULT_PROTOCOL; private String host = DEFAULT_HOST; private int port = DEFAULT_PORT; + private int socketTimeout = DEFAULT_SOCKETTIMEOUT; private String uriPattern; // Optional and for consumer only. This allows a single route to service multiple URI patterns. @@ -124,6 +126,14 @@ public class RestletEndpoint extends DefaultEndpoint implements HeaderFilterStra this.port = port; } + public int getSocketTimeout() { + return socketTimeout; + } + + public void setSocketTimeout(int socketTimeout) { + this.socketTimeout = socketTimeout; + } + public String getUriPattern() { return uriPattern; } http://git-wip-us.apache.org/repos/asf/camel/blob/1e269c86/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 b8d84c4..2cad21f 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 @@ -49,6 +49,7 @@ public class RestletProducer extends DefaultAsyncProducer { this.throwException = endpoint.isThrowExceptionOnFailure(); client = new Client(endpoint.getProtocol()); client.setContext(new Context()); + client.getContext().getParameters().add("socketTimeout", String.valueOf(endpoint.getSocketTimeout())); } @Override @@ -98,10 +99,10 @@ public class RestletProducer extends DefaultAsyncProducer { } catch (Exception e) { exchange.setException(e); } - callback.done(false); } }); + callback.done(false); return false; }
