You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2018/10/18 16:02:29 UTC

[camel] 05/45: CAMEL-12880 : Atom consumer stops polling

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 <sa...@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();