From faa76977c193a422bec7c438ca35c34fc507b3d0 Mon Sep 17 00:00:00 2001 From: Ryan Baxter Date: Fri, 2 Oct 2020 10:02:25 -0400 Subject: [PATCH] Do not run post processor if bus is disabled --- .../cloud/bus/BusEnvironmentPostProcessor.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusEnvironmentPostProcessor.java b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusEnvironmentPostProcessor.java index 4629aba..8b21982 100644 --- a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusEnvironmentPostProcessor.java +++ b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusEnvironmentPostProcessor.java @@ -46,6 +46,12 @@ public class BusEnvironmentPostProcessor implements EnvironmentPostProcessor { @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 overrides = new HashMap<>(); String definition = BusConstants.BUS_CONSUMER; if (environment.containsProperty(FN_DEF_PROP)) {