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 <[email protected]> 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() {
