diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2018-02-16 14:22:50 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2018-02-16 14:22:50 +0100 |
commit | 6b6125b3f6650aa642f54ac5c3708f337d01e72b (patch) | |
tree | 576ba9eb1ce37549c5c297e578af5c2eb37049ea | |
parent | 7a2d217d927712190fc2be1cdb42c7d6d6758791 (diff) |
Same pattern as for FileConfigSubscription
-rw-r--r-- | config/src/main/java/com/yahoo/config/subscription/impl/ConfigSetSubscription.java | 9 |
1 files changed, 2 insertions, 7 deletions
diff --git a/config/src/main/java/com/yahoo/config/subscription/impl/ConfigSetSubscription.java b/config/src/main/java/com/yahoo/config/subscription/impl/ConfigSetSubscription.java index 204284e22d0..45b0df3cb63 100644 --- a/config/src/main/java/com/yahoo/config/subscription/impl/ConfigSetSubscription.java +++ b/config/src/main/java/com/yahoo/config/subscription/impl/ConfigSetSubscription.java @@ -39,11 +39,11 @@ public class ConfigSetSubscription<T extends ConfigInstance> extends ConfigSubsc ConfigState<T> configState = getConfigState(); // User forced reload if (checkReloaded()) { - updateInstance(myInstance); + setConfigIfChanged((T)myInstance); return true; } if (!myInstance.equals(configState.getConfig())) { - updateInstance(myInstance); + setConfigIfChangedIncGen((T)myInstance); return true; } sleep(); @@ -59,11 +59,6 @@ public class ConfigSetSubscription<T extends ConfigInstance> extends ConfigSubsc } } - @SuppressWarnings("unchecked") - private void updateInstance(ConfigInstance myInstance) { - setConfigIfChangedIncGen((T)myInstance); - } - @Override public boolean subscribe(long timeout) { return true; |