diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java index 3633c74e5..199551fb6 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java @@ -113,15 +113,12 @@ public class BindingService { bindings.add(doBindConsumer(input, inputName, binder, consumerProperties, bindingTarget)); } else { - String[] bindingTargets = StringUtils - .commaDelimitedListToStringArray(bindingTarget); + String[] bindingTargets = StringUtils.commaDelimitedListToStringArray(bindingTarget); for (String target : bindingTargets) { - Binding binding; - if (input instanceof PollableSource) { - binding = doBindPollableConsumer(input, inputName, binder, consumerProperties, target); - } else { - binding = doBindConsumer(input, inputName, binder, consumerProperties, target); - } + Binding binding = input instanceof PollableSource + ? doBindPollableConsumer(input, inputName, binder, consumerProperties, target) + : doBindConsumer(input, inputName, binder, consumerProperties, target); + bindings.add(binding); } }