diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2018-02-16 11:27:33 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2018-02-16 11:27:33 +0100 |
commit | d3612c8b4abdd2583f841bef01073f8aaf1a00f7 (patch) | |
tree | f44c24281f8b8197ac7e97b5df3879b9ec921366 /config-proxy | |
parent | 87a68b75d729960da7fcada2fc3a7c30119074ed (diff) |
Let RawConfig be a ConfigInstance
Diffstat (limited to 'config-proxy')
-rw-r--r-- | config-proxy/src/main/java/com/yahoo/vespa/config/proxy/UpstreamConfigSubscriber.java | 15 |
1 files changed, 8 insertions, 7 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 a52aa6d7216..528c61fe132 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 @@ -7,6 +7,7 @@ import com.yahoo.config.subscription.impl.GenericConfigHandle; import com.yahoo.config.subscription.impl.GenericConfigSubscriber; import com.yahoo.config.subscription.impl.JRTConfigRequester; import com.yahoo.log.LogLevel; +import com.yahoo.vespa.config.ConfigKey; import com.yahoo.yolean.Exceptions; import com.yahoo.vespa.config.RawConfig; import com.yahoo.vespa.config.TimingValues; @@ -30,12 +31,10 @@ public class UpstreamConfigSubscriber implements Subscriber { private GenericConfigSubscriber subscriber; private GenericConfigHandle handle; - UpstreamConfigSubscriber(RawConfig config, - ClientUpdater clientUpdater, - ConfigSource configSourceSet, - TimingValues timingValues, - Map<ConfigSourceSet, JRTConfigRequester> requesterPool, - MemoryCache memoryCache) { + UpstreamConfigSubscriber(RawConfig config, ClientUpdater clientUpdater, ConfigSource configSourceSet, + TimingValues timingValues, Map<ConfigSourceSet, JRTConfigRequester> requesterPool, + MemoryCache memoryCache) + { this.config = config; this.clientUpdater = clientUpdater; this.configSourceSet = configSourceSet; @@ -46,7 +45,9 @@ public class UpstreamConfigSubscriber implements Subscriber { void subscribe() { subscriber = new GenericConfigSubscriber(requesterPool); - handle = subscriber.subscribe(config.getKey(), config.getDefContent(), configSourceSet, timingValues); + ConfigKey<?> key = config.getKey(); + handle = subscriber.subscribe(new ConfigKey<RawConfig>(key.getName(), key.getConfigId(), key.getNamespace()), + config.getDefContent(), configSourceSet, timingValues); } @Override |