diff --git a/starters/threadpool/config/src/main/java/cn/hippo4j/config/springboot/starter/refresher/ConsulRefresherHandler.java b/starters/threadpool/config/src/main/java/cn/hippo4j/config/springboot/starter/refresher/ConsulRefresherHandler.java index ea2cca4e..0f0dd23b 100644 --- a/starters/threadpool/config/src/main/java/cn/hippo4j/config/springboot/starter/refresher/ConsulRefresherHandler.java +++ b/starters/threadpool/config/src/main/java/cn/hippo4j/config/springboot/starter/refresher/ConsulRefresherHandler.java @@ -41,6 +41,8 @@ public class ConsulRefresherHandler extends AbstractConfigThreadPoolDynamicRefre private static final int INITIAL_CAPACITY = 64; + private static final String DEFAULT_CONTEXT = "spring.cloud.consul.config.default-context"; + @EventListener(EnvironmentChangeEvent.class) public void refreshed(EnvironmentChangeEvent event) { Map configInfo = extractLatestConfigInfo(event); @@ -70,7 +72,7 @@ public class ConsulRefresherHandler extends AbstractConfigThreadPoolDynamicRefre private CharSequence getApplicationConfigDefaultContext(AbstractEnvironment environment) { return environment.getPropertySources().stream() .filter(propertySource -> propertySource instanceof OriginTrackedMapPropertySource) - .map(propertySource -> ((Map) propertySource.getSource()).get("spring.cloud.consul.config.default-context")) + .map(propertySource -> ((Map) propertySource.getSource()).get(DEFAULT_CONTEXT)) .findFirst().orElse(StringUtils.EMPTY); }