From 8369519b0b536e643980f0eef2ba169051ee4045 Mon Sep 17 00:00:00 2001 From: Jon Marius Venstad Date: Wed, 7 Oct 2020 19:42:03 +0200 Subject: Zero delay — just the 10ms throttle wait — for throttle queue MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'vespaclient-container-plugin') 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; -- cgit v1.2.3