summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2021-11-10 19:07:09 +0100
committerHarald Musum <musum@yahooinc.com>2021-11-10 19:07:09 +0100
commita218ec7919bb0a06708c08759bda962dbad01b90 (patch)
tree3c66c55a60f7de97d541036a34f686c9bd59db96
parent3df83ad9db9b5ecddf349db348b54e93b6f66c85 (diff)
Implement setNewConfigAndGeneration in GenericJRTConfigSubscription
-rw-r--r--config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java11
1 files changed, 11 insertions, 0 deletions
diff --git a/config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java b/config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java
index dbe13e90c9c..354489ea946 100644
--- a/config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java
+++ b/config/src/main/java/com/yahoo/config/subscription/impl/GenericJRTConfigSubscription.java
@@ -49,6 +49,17 @@ public class GenericJRTConfigSubscription extends JRTConfigSubscription<RawConfi
}
}
+ // Need to override this method, since we use RawConfig in this class,
+ @Override
+ protected void setNewConfigAndGeneration(JRTClientConfigRequest jrtReq) {
+ // Set generation first, as RawConfig contains generation and that
+ // will make configChanged in ConfigState always true otherwise
+ // (see equals usage in setConfigAndGeneration())
+ setGeneration(jrtReq.getNewGeneration());
+ RawConfig rawConfig = RawConfig.createFromResponseParameters(jrtReq);
+ setConfigAndGeneration(jrtReq.getNewGeneration(), jrtReq.responseIsApplyOnRestart(), rawConfig, jrtReq.getNewChecksums());
+ }
+
// Override to propagate internal redeploy into the config value in addition to the config state
@Override
void setApplyOnRestart(boolean applyOnRestart) {