diff options
Diffstat (limited to 'vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java')
-rw-r--r-- | vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java index 7238a0c4ba7..afa4cd0ae14 100644 --- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java +++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/api/FeedClientImpl.java @@ -11,6 +11,7 @@ import com.yahoo.vespa.http.client.core.operationProcessor.OperationProcessor; import java.nio.charset.CharsetEncoder; import java.nio.charset.CodingErrorAction; import java.nio.charset.StandardCharsets; +import java.time.Clock; import java.time.Instant; import java.util.Optional; import java.util.concurrent.ScheduledThreadPoolExecutor; @@ -29,7 +30,8 @@ public class FeedClientImpl implements FeedClient { public FeedClientImpl(SessionParams sessionParams, ResultCallback resultCallback, - ScheduledThreadPoolExecutor timeoutExecutor) { + ScheduledThreadPoolExecutor timeoutExecutor, + Clock clock) { this.closeTimeoutMs = (10 + 3 * sessionParams.getConnectionParams().getMaxRetries()) * ( sessionParams.getFeedParams().getServerTimeout(TimeUnit.MILLISECONDS) + sessionParams.getFeedParams().getClientTimeout(TimeUnit.MILLISECONDS)); @@ -41,7 +43,8 @@ public class FeedClientImpl implements FeedClient { new ThrottlePolicy()), resultCallback, sessionParams, - timeoutExecutor); + timeoutExecutor, + clock); } @Override |