aboutsummaryrefslogtreecommitdiffstats
path: root/config-proxy
diff options
context:
space:
mode:
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();
}