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() {