summaryrefslogtreecommitdiffstats
path: root/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/UpstreamConfigSubscriber.java
diff options
context:
space:
mode:
Diffstat (limited to 'config-proxy/src/main/java/com/yahoo/vespa/config/proxy/UpstreamConfigSubscriber.java')
-rw-r--r--config-proxy/src/main/java/com/yahoo/vespa/config/proxy/UpstreamConfigSubscriber.java10
1 files changed, 5 insertions, 5 deletions
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/UpstreamConfigSubscriber.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/UpstreamConfigSubscriber.java
index 528c61fe132..ceaf57e9cf1 100644
--- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/UpstreamConfigSubscriber.java
+++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/UpstreamConfigSubscriber.java
@@ -17,9 +17,9 @@ import java.util.logging.Logger;
/**
* @author hmusum
- * @since 5.5
*/
public class UpstreamConfigSubscriber implements Subscriber {
+
private final static Logger log = Logger.getLogger(UpstreamConfigSubscriber.class.getName());
private final RawConfig config;
@@ -33,8 +33,7 @@ public class UpstreamConfigSubscriber implements Subscriber {
UpstreamConfigSubscriber(RawConfig config, ClientUpdater clientUpdater, ConfigSource configSourceSet,
TimingValues timingValues, Map<ConfigSourceSet, JRTConfigRequester> requesterPool,
- MemoryCache memoryCache)
- {
+ MemoryCache memoryCache) {
this.config = config;
this.clientUpdater = clientUpdater;
this.configSourceSet = configSourceSet;
@@ -46,7 +45,7 @@ public class UpstreamConfigSubscriber implements Subscriber {
void subscribe() {
subscriber = new GenericConfigSubscriber(requesterPool);
ConfigKey<?> key = config.getKey();
- handle = subscriber.subscribe(new ConfigKey<RawConfig>(key.getName(), key.getConfigId(), key.getNamespace()),
+ handle = subscriber.subscribe(new ConfigKey<>(key.getName(), key.getConfigId(), key.getNamespace()),
config.getDefContent(), configSourceSet, timingValues);
}
@@ -66,7 +65,7 @@ public class UpstreamConfigSubscriber implements Subscriber {
}
private void updateWithNewConfig(GenericConfigHandle handle) {
- final RawConfig newConfig = handle.getRawConfig();
+ RawConfig newConfig = handle.getRawConfig();
if (log.isLoggable(LogLevel.DEBUG)) {
log.log(LogLevel.DEBUG, "config to be returned for '" + newConfig.getKey() +
"', generation=" + newConfig.getGeneration() +
@@ -82,4 +81,5 @@ public class UpstreamConfigSubscriber implements Subscriber {
subscriber.close();
}
}
+
}