INNER CODE UNIT · Java

BusEnvironmentPostProcessor

spring-cloud/spring-cloud-bus · spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusEnvironmentPostProcessor.java:40

public class BusEnvironmentPostProcessor implements EnvironmentPostProcessor {

	static final String DEFAULTS_PROPERTY_SOURCE_NAME = "springCloudBusDefaultProperties";

	static final String OVERRIDES_PROPERTY_SOURCE_NAME = "springCloudBusOverridesProperties";

	private static final String FN_DEF_PROP = FunctionProperties.PREFIX + ".definition";

	@Override
	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;

View source record →