camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [camel] 05/45: CAMEL-12880 : Atom consumer stops polling
Date Thu, 18 Oct 2018 16:02:29 GMT
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch sandbox/camel-3.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 9f162ac436f91d6b594f119e4f40bc09175c8aef
Author: Saravanakumar Selvaraj <saravanakumar.java@gmail.com>
AuthorDate: Sun Oct 14 20:22:50 2018 +0530

    CAMEL-12880 : Atom consumer stops polling
---
 .../src/main/java/org/apache/camel/component/atom/AtomUtils.java        | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomUtils.java
b/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomUtils.java
index f6e9b2c..0571cd8 100644
--- a/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomUtils.java
+++ b/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomUtils.java
@@ -60,6 +60,8 @@ public final class AtomUtils {
     public static Document<Feed> parseDocument(String uri, String username, String
password) throws IOException {
         URL feedUrl = new URL(uri);
         HttpURLConnection httpcon = (HttpURLConnection) feedUrl.openConnection();
+        httpcon.setConnectTimeout(60000);
+        httpcon.setReadTimeout(60000);
         String encoding = Base64.encodeBase64String(username.concat(":").concat(password).getBytes());
         httpcon.setRequestProperty("Authorization", "Basic " + encoding);
         InputStream in = httpcon.getInputStream();


Mime
View raw message