diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java index 2fa9be83f..02cf10ff0 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java @@ -923,9 +923,8 @@ public class FunctionConfiguration { String[] inputBindings = StringUtils.hasText(bindingProperties.getInputBindings()) ? bindingProperties.getInputBindings().split(";") : new String[0]; - String[] outputBindings = StringUtils.hasText(bindingProperties.getOutputBindings()) ? bindingProperties.getOutputBindings().split(";") : ( - StringUtils.hasText(bindingProperties.getOutputBindings()) ? bindingProperties.getOutputBindings().split(";") : new String[0] - ); + String[] outputBindings = StringUtils.hasText(bindingProperties.getOutputBindings()) + ? bindingProperties.getOutputBindings().split(";") : new String[0]; for (String inputBindingName : inputBindings) { FunctionInvocationWrapper sourceFunc = functionCatalog.lookup(inputBindingName);