From 58efbb15865ce458cb65956d9183cd3a014ec45f Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Wed, 26 Feb 2020 19:47:27 +0100 Subject: [PATCH] Polishing previous work --- .../cloud/stream/function/FunctionConfiguration.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java index c907eb053..323289607 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java @@ -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 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));