INNER CODE UNIT · Java
postProcessEnvironment
spring-cloud/spring-cloud-bus · spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusEnvironmentPostProcessor.java:49
public void postProcessEnvironment(ConfigurableEnvironment environment, SpringApplication application) {
if (environment.containsProperty(ConditionalOnBusEnabled.SPRING_CLOUD_BUS_ENABLED)) {
if (Boolean.FALSE.toString()
.equalsIgnoreCase(environment.getProperty(ConditionalOnBusEnabled.SPRING_CLOUD_BUS_ENABLED))) {
return;
}
}
Map<String, Object> overrides = new HashMap<>();
String definition = BusConstants.BUS_CONSUMER;
if (environment.containsProperty(FN_DEF_PROP)) {
String property = environment.getProperty(FN_DEF_PROP);
if (property != null && property.contains(BusConstants.BUS_CONSUMER)) {
// in the case that EnvironmentPostProcessor are run more than once.
return;
}
definition = property + ";" + definition;
}
overrides.put(FN_DEF_PROP, definition);