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 978d4339..62428bfa 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, () -> { - wait(properties); - restarter.get().restart(); - }); - } - case REFRESH -> new ConfigurationUpdateStrategy(strategyName, refresher::refresh); - case SHUTDOWN -> new ConfigurationUpdateStrategy(strategyName, () -> { + case RESTART_CONTEXT -> { + restarter.orElseThrow(() -> new AssertionError("Restart endpoint is not enabled")); + yield new ConfigurationUpdateStrategy(strategyName, () -> { wait(properties); - ctx.close(); + restarter.get().restart(); }); + } + case REFRESH -> new ConfigurationUpdateStrategy(strategyName, refresher::refresh); + case SHUTDOWN -> new ConfigurationUpdateStrategy(strategyName, () -> { + wait(properties); + ctx.close(); + }); }; }