SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing, formatting

Browse Source 
Resolves #1366
This commit is contained in:
Oleg Zhurakousky
2018-04-27 08:54:25 +02:00
parent 61bce52722
commit 7be8ea59e9
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java
View File

@@ -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<T> binding;
if (input instanceof PollableSource) {
binding = doBindPollableConsumer(input, inputName, binder, consumerProperties, target);
} else {
binding = doBindConsumer(input, inputName, binder, consumerProperties, target);
}
Binding<T> binding = input instanceof PollableSource
? doBindPollableConsumer(input, inputName, binder, consumerProperties, target)
: doBindConsumer(input, inputName, binder, consumerProperties, target);
bindings.add(binding);
}
}