diff options
Diffstat (limited to 'config/src/main/java/com/yahoo/config/subscription/impl/JrtConfigRequesters.java')
-rw-r--r-- | config/src/main/java/com/yahoo/config/subscription/impl/JrtConfigRequesters.java | 38 |
1 files changed, 0 insertions, 38 deletions
diff --git a/config/src/main/java/com/yahoo/config/subscription/impl/JrtConfigRequesters.java b/config/src/main/java/com/yahoo/config/subscription/impl/JrtConfigRequesters.java deleted file mode 100644 index 1e9612272d5..00000000000 --- a/config/src/main/java/com/yahoo/config/subscription/impl/JrtConfigRequesters.java +++ /dev/null @@ -1,38 +0,0 @@ -// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.config.subscription.impl; - -import com.yahoo.config.subscription.ConfigSourceSet; -import com.yahoo.vespa.config.TimingValues; - -import java.util.HashMap; -import java.util.Map; - -/** - * Keeps track of requesters per config subscriber - * - * @author hmusum - */ -public class JrtConfigRequesters { - - /** - * Reuse requesters for equal source sets, limit number if many subscriptions. - */ - protected Map<ConfigSourceSet, JRTConfigRequester> requesters = new HashMap<>(); - - public JRTConfigRequester getRequester(ConfigSourceSet source, TimingValues timingValues) { - JRTConfigRequester requester = requesters.get(source); - if (requester == null) { - requester = JRTConfigRequester.create(source, timingValues); - requesters.put(source, requester); - } - return requester; - } - - /** - * Closes all open requesters - */ - public void close() { - requesters.values().forEach(JRTConfigRequester::close); - } - -} |