diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2020-10-07 19:42:03 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2020-10-07 19:42:03 +0200 |
commit | 8369519b0b536e643980f0eef2ba169051ee4045 (patch) | |
tree | 2efa00c628c314ccd2f17fc4aa6ea4b0dba6a348 /vespaclient-container-plugin | |
parent | 10f3a803e1985b7bc1c09323d8da50f3eb2bbfd1 (diff) |
Zero delay — just the 10ms throttle wait — for throttle queue
Diffstat (limited to 'vespaclient-container-plugin')
-rw-r--r-- | vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java index 83640451601..309bed38c0b 100644 --- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java +++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java @@ -107,7 +107,7 @@ public class DocumentOperationExecutorImpl implements DocumentOperationExecutor this.asyncSession = access.createAsyncSession(new AsyncParameters()); this.clock = requireNonNull(clock); this.clusters = Map.copyOf(clusters); - this.throttled = new DelayQueue(maxThrottled, this::send, resendDelay, clock, "throttle"); + this.throttled = new DelayQueue(maxThrottled, this::send, Duration.ZERO, clock, "throttle"); this.timeouts = new DelayQueue(Long.MAX_VALUE, (__, context) -> { context.error(TIMEOUT, "Timed out after " + defaultTimeout); return true; |