camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject [2/3] git commit: CAMEL-7014 setup the client timeout of camel-restlet with thanks of Benjamin
Date Mon, 06 Jan 2014 07:43:37 GMT
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.jiang@gmail.com>
Authored: Mon Jan 6 14:23:32 2014 +0800
Committer: Willem Jiang <willem.jiang@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;
     }
 


Mime
View raw message