diff options
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.java | 4 |
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); } |