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 2019/05/09 08:22:16 UTC

[camel] 01/03: Camel-Soroush: Align okhttp-sse to okhttp version widely used in the project

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 874c524e3a89525941cdff1438bce82e542eafcf
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu May 9 10:13:14 2019 +0200

    Camel-Soroush: Align okhttp-sse to okhttp version widely used in the project
---
 components/camel-soroush/pom.xml                                    | 2 +-
 .../component/soroushbot/component/SoroushBotAbstractConsumer.java  | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/components/camel-soroush/pom.xml b/components/camel-soroush/pom.xml
index 53ffe03..6d4dd206 100644
--- a/components/camel-soroush/pom.xml
+++ b/components/camel-soroush/pom.xml
@@ -39,7 +39,7 @@
         <dependency>
             <groupId>com.squareup.okhttp3</groupId>
             <artifactId>okhttp-sse</artifactId>
-            <version>${squareup-okhttp3-version}</version>
+            <version>${okclient-version}</version>
         </dependency>
         <dependency>
             <groupId>org.glassfish.jersey.core</groupId>
diff --git a/components/camel-soroush/src/main/java/org/apache/camel/component/soroushbot/component/SoroushBotAbstractConsumer.java b/components/camel-soroush/src/main/java/org/apache/camel/component/soroushbot/component/SoroushBotAbstractConsumer.java
index ff4dbd0..02bc7ea 100644
--- a/components/camel-soroush/src/main/java/org/apache/camel/component/soroushbot/component/SoroushBotAbstractConsumer.java
+++ b/components/camel-soroush/src/main/java/org/apache/camel/component/soroushbot/component/SoroushBotAbstractConsumer.java
@@ -84,9 +84,9 @@ public abstract class SoroushBotAbstractConsumer extends DefaultConsumer impleme
                 .build();
         OkHttpClient client = new OkHttpClient.Builder()
                 .connectTimeout(endpoint.connectionTimeout, TimeUnit.MILLISECONDS)
-                .writeTimeout(Duration.ZERO)
-                .readTimeout(Duration.ZERO)
-                .callTimeout(Duration.ZERO).build();
+                .writeTimeout(0L, TimeUnit.MILLISECONDS)
+                .readTimeout(0L, TimeUnit.MILLISECONDS)
+                .build();
         connection = new ReconnectableEventSourceListener(client, request, endpoint.maxConnectionRetry) {
             @Override
             protected boolean onBeforeConnect() {