aboutsummaryrefslogtreecommitdiffstats
path: root/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/ClusterConnection.java
diff options
context:
space:
mode:
Diffstat (limited to 'vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/ClusterConnection.java')
-rw-r--r--vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/ClusterConnection.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/ClusterConnection.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/ClusterConnection.java
index c50f9420973..319a925611a 100644
--- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/ClusterConnection.java
+++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/ClusterConnection.java
@@ -14,6 +14,7 @@ import com.yahoo.vespa.http.client.core.operationProcessor.OperationProcessor;
import java.io.IOException;
import java.io.StringWriter;
+import java.time.Duration;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ScheduledThreadPoolExecutor;
@@ -85,9 +86,10 @@ public class ClusterConnection implements AutoCloseable {
clusterId,
feedParams.getMaxChunkSizeBytes(),
maxInFlightPerSession,
- feedParams.getLocalQueueTimeOut(),
+ Duration.ofMillis(feedParams.getLocalQueueTimeOut()),
documentQueue,
feedParams.getMaxSleepTimeMs(),
+ connectionParams.getConnectionTimeToLive(),
idlePollFrequency);
ioThreads.add(ioThread);
}