From 6336f058f01ddcb0b0c1f895d03e5a7dea38120a Mon Sep 17 00:00:00 2001 From: buildmaster Date: Mon, 12 Sep 2022 04:00:00 +0000 Subject: [PATCH] Bumping versions --- .../reload/ConfigReloadAutoConfiguration.java | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/config/reload/ConfigReloadAutoConfiguration.java b/spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/config/reload/ConfigReloadAutoConfiguration.java index 62428bfa..978d4339 100644 --- a/spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/config/reload/ConfigReloadAutoConfiguration.java +++ b/spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/config/reload/ConfigReloadAutoConfiguration.java @@ -65,18 +65,18 @@ public class ConfigReloadAutoConfiguration { ConfigurableApplicationContext ctx, Optional restarter, ContextRefresher refresher) { String strategyName = properties.getStrategy().name(); return switch (properties.getStrategy()) { - case RESTART_CONTEXT -> { - restarter.orElseThrow(() -> new AssertionError("Restart endpoint is not enabled")); - yield new ConfigurationUpdateStrategy(strategyName, () -> { + case RESTART_CONTEXT -> { + restarter.orElseThrow(() -> new AssertionError("Restart endpoint is not enabled")); + yield new ConfigurationUpdateStrategy(strategyName, () -> { + wait(properties); + restarter.get().restart(); + }); + } + case REFRESH -> new ConfigurationUpdateStrategy(strategyName, refresher::refresh); + case SHUTDOWN -> new ConfigurationUpdateStrategy(strategyName, () -> { wait(properties); - restarter.get().restart(); + ctx.close(); }); - } - case REFRESH -> new ConfigurationUpdateStrategy(strategyName, refresher::refresh); - case SHUTDOWN -> new ConfigurationUpdateStrategy(strategyName, () -> { - wait(properties); - ctx.close(); - }); }; }