This is an automated email from the ASF dual-hosted git repository. riemer pushed a commit to branch fix-influx-client in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 12a53ceef9d25e2ff2f0a2cf0378a98d8c085d87 Author: Dominik Riemer <[email protected]> AuthorDate: Mon Dec 16 09:54:38 2024 +0100 fix: Reuse Influx connection pool --- .../streampipes/dataexplorer/influx/client/InfluxClientUtils.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/streampipes-data-explorer-influx/src/main/java/org/apache/streampipes/dataexplorer/influx/client/InfluxClientUtils.java b/streampipes-data-explorer-influx/src/main/java/org/apache/streampipes/dataexplorer/influx/client/InfluxClientUtils.java index 9b0d14d1ce..40f67fd780 100644 --- a/streampipes-data-explorer-influx/src/main/java/org/apache/streampipes/dataexplorer/influx/client/InfluxClientUtils.java +++ b/streampipes-data-explorer-influx/src/main/java/org/apache/streampipes/dataexplorer/influx/client/InfluxClientUtils.java @@ -20,12 +20,15 @@ package org.apache.streampipes.dataexplorer.influx.client; import org.apache.streampipes.dataexplorer.influx.auth.AuthInterceptor; +import okhttp3.ConnectionPool; import okhttp3.OkHttpClient; import java.util.concurrent.TimeUnit; public class InfluxClientUtils { + private static final ConnectionPool connectionPool = new ConnectionPool(10, 10, TimeUnit.MINUTES); + public static OkHttpClient.Builder getHttpClientBuilder(String authToken) { var builder = getHttpClientBuilder() .addInterceptor(new AuthInterceptor(authToken)); @@ -35,6 +38,7 @@ public class InfluxClientUtils { public static OkHttpClient.Builder getHttpClientBuilder() { return new OkHttpClient().newBuilder() + .connectionPool(connectionPool) .connectTimeout(120, TimeUnit.SECONDS) .readTimeout(120, TimeUnit.SECONDS) .writeTimeout(120, TimeUnit.SECONDS);
