diff options
author | gjoranv <gv@verizonmedia.com> | 2021-10-15 12:27:26 +0200 |
---|---|---|
committer | gjoranv <gv@verizonmedia.com> | 2021-10-15 12:27:26 +0200 |
commit | 9e8e87e17a282ae396c40717b4f8caccf155c53c (patch) | |
tree | 6240005ac3d83534bb406c07ae652167f7c4fe54 /container-disc | |
parent | f2781d1ecbbaf1214463e76eca3359a386d23d70 (diff) |
Reapply "Container config improvements [run-systemtest]"
This reverts commit 868c29b272eb7773d5c4515cb33640a44074d05a.
Diffstat (limited to 'container-disc')
-rw-r--r-- | container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java b/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java index 219616500c8..099df79cd9b 100644 --- a/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java +++ b/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java @@ -212,7 +212,8 @@ public final class ConfiguredApplication implements Application { } private <T extends ConfigInstance> T getConfig(Class<T> configClass, boolean isInitializing) { - Subscriber subscriber = subscriberFactory.getSubscriber(Collections.singleton(new ConfigKey<>(configClass, configId))); + Subscriber subscriber = subscriberFactory.getSubscriber(Collections.singleton(new ConfigKey<>(configClass, configId)), + configClass.getName()); try { subscriber.waitNextGeneration(isInitializing); return configClass.cast(first(subscriber.config().values())); @@ -222,7 +223,8 @@ public final class ConfiguredApplication implements Application { } private void watchPortChange() { - Subscriber subscriber = subscriberFactory.getSubscriber(Collections.singleton(new ConfigKey<>(QrConfig.class, configId))); + Subscriber subscriber = subscriberFactory.getSubscriber(Collections.singleton(new ConfigKey<>(QrConfig.class, configId)), + "portWatcher"); try { while (true) { subscriber.waitNextGeneration(false); |