SpringCloud/spring-cloud-kubernetes
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

change switch to jdk-17 (#1070)

Browse Source
This commit is contained in:
erabii
2022-09-10 16:00:22 +03:00
committed by GitHub
parent 6ef88ec97a
commit 016ec7191e
1 changed files with 11 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/config/reload/ConfigReloadAutoConfiguration.java
View File

@@ -64,22 +64,20 @@ public class ConfigReloadAutoConfiguration {
public ConfigurationUpdateStrategy configurationUpdateStrategy(ConfigReloadProperties properties,
ConfigurableApplicationContext ctx, Optional<RestartEndpoint> restarter, ContextRefresher refresher) {
String strategyName = properties.getStrategy().name();
switch (properties.getStrategy()) {
case RESTART_CONTEXT:
restarter.orElseThrow(() -> new AssertionError("Restart endpoint is not enabled"));
return new ConfigurationUpdateStrategy(strategyName, () -> {
wait(properties);
restarter.get().restart();
});
case REFRESH:
return new ConfigurationUpdateStrategy(strategyName, refresher::refresh);
case SHUTDOWN:
return new ConfigurationUpdateStrategy(strategyName, () -> {
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, () -> {
wait(properties);
ctx.close();
});
}
throw new IllegalStateException("Unsupported configuration update strategy: " + strategyName);
};
}
private static void wait(ConfigReloadProperties properties) {