diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/RoutingFunctionEnvironmentPostProcessor.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/RoutingFunctionEnvironmentPostProcessor.java index f2156faaec..7e37deb04c 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/RoutingFunctionEnvironmentPostProcessor.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/RoutingFunctionEnvironmentPostProcessor.java @@ -38,11 +38,11 @@ public void postProcessEnvironment(ConfigurableEnvironment environment, SpringAp name.contains(RoutingFunction.FUNCTION_NAME + "|") || name.contains("|" + RoutingFunction.FUNCTION_NAME) )) { - ((StandardEnvironment) environment).getSystemProperties() + environment.getSystemProperties() .putIfAbsent("spring.cloud.function.routing.enabled", "true"); } // perhaps mpve it to separate class as it doesn't have much to do with RoutingFunction - ((StandardEnvironment) environment).getSystemProperties() + environment.getSystemProperties() .putIfAbsent("spring.cloud.function.configuration.default.copy-input-headers", "true"); }