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 d591fddc2..3574b579f 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 @@ -904,9 +904,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);