aboutsummaryrefslogtreecommitdiffstats
path: root/config-proxy
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2020-09-15 14:51:38 +0200
committerHarald Musum <musum@verizonmedia.com>2020-09-15 14:51:38 +0200
commit6fb77e947c67da3e5bd0fc5c047e6421bfd75cd6 (patch)
treefa7baeda89cd82f70f4077b3dd2e858c36bf4a67 /config-proxy
parent5fe6528124a2dc760e0770238d11259469eb18ca (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.java6
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();
}