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

GH-2229 behavior of when there is a single function bean in context

Browse Source 
Resolves #2229
This commit is contained in:
Oleg Zhurakousky
2021-10-06 11:03:26 +02:00
parent b44e55d247
commit 633bc7b168
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -848,7 +848,10 @@ public class FunctionConfiguration {
String[] sourceNames = this.environment.getProperty(SOURCE_PROPERY).split(";");
for (String sourceName : sourceNames) {
if (functionCatalog.lookup(sourceName) == null) {
FunctionInvocationWrapper sourceFunc = functionCatalog.lookup(sourceName);
if (sourceFunc == null || //see https://github.com/spring-cloud/spring-cloud-stream/issues/2229
(!sourceFunc.getFunctionDefinition().equals(sourceName) && applicationContext.containsBean(sourceName))) {
RootBeanDefinition functionBindableProxyDefinition = new RootBeanDefinition(BindableFunctionProxyFactory.class);
functionBindableProxyDefinition.getConstructorArgumentValues().addGenericArgumentValue(sourceName);
functionBindableProxyDefinition.getConstructorArgumentValues().addGenericArgumentValue(0);