diff options
author | Harald Musum <musum@verizonmedia.com> | 2020-09-15 14:51:38 +0200 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2020-09-15 14:51:38 +0200 |
commit | 6fb77e947c67da3e5bd0fc5c047e6421bfd75cd6 (patch) | |
tree | fa7baeda89cd82f70f4077b3dd2e858c36bf4a67 /config-proxy | |
parent | 5fe6528124a2dc760e0770238d11259469eb18ca (diff) |
Shutdown immediately, no point in waiting for this component
Diffstat (limited to 'config-proxy')
-rw-r--r-- | config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java index 75866ec73ab..d557393638d 100644 --- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java +++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java @@ -181,9 +181,9 @@ class RpcConfigSourceClient implements ConfigSourceClient, Runnable { public void cancel() { shutdownSourceConnections(); delayedResponsesFuture.cancel(true); - delayedResponsesScheduler.shutdown(); + delayedResponsesScheduler.shutdownNow(); nextConfigFuture.cancel(true); - nextConfigScheduler.shutdown(); + nextConfigScheduler.shutdownNow(); } /** @@ -193,7 +193,7 @@ class RpcConfigSourceClient implements ConfigSourceClient, Runnable { public void shutdownSourceConnections() { activeSubscribers.values().forEach(Subscriber::cancel); activeSubscribers.clear(); - nextConfigScheduler.shutdown(); + nextConfigScheduler.shutdownNow(); requester.close(); } |