summaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2020-10-07 19:42:03 +0200
committerJon Marius Venstad <venstad@gmail.com>2020-10-07 19:42:03 +0200
commit8369519b0b536e643980f0eef2ba169051ee4045 (patch)
tree2efa00c628c314ccd2f17fc4aa6ea4b0dba6a348 /vespaclient-container-plugin
parent10f3a803e1985b7bc1c09323d8da50f3eb2bbfd1 (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.java2
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;