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

Polishing previous work

Browse Source
This commit is contained in:
Oleg Zhurakousky
2020-02-26 19:47:27 +01:00
parent f25d37683f
commit 58efbb1586
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
View File

@@ -101,6 +101,7 @@ import org.springframework.messaging.SubscribableChannel;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.util.Assert;
import org.springframework.util.ClassUtils;
import org.springframework.util.CollectionUtils;
import org.springframework.util.ObjectUtils;
import org.springframework.util.ReflectionUtils;
import org.springframework.util.StringUtils;
@@ -503,6 +504,9 @@ public class FunctionConfiguration {
private String determineOutputDestinationName(int index, BindableProxyFactory bindableProxyFactory, Type functionType) {
List<String> outputNames = new ArrayList<>(bindableProxyFactory.getOutputs());
if (CollectionUtils.isEmpty(outputNames)) {
outputNames = Collections.singletonList("output");
}
String outputDestinationName = bindableProxyFactory instanceof BindableFunctionProxyFactory
? ((BindableFunctionProxyFactory) bindableProxyFactory).getOutputName(index)
: (FunctionTypeUtils.isConsumer(functionType) ? null : outputNames.get(index));