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

Add consumer lookup, for single consumer in catalog

Browse Source 
Related to issue #454

Resolves #455
This commit is contained in:
Arno
2020-03-05 15:52:44 +01:00
committed by Oleg Zhurakousky
parent 1d2377ef85
commit 013e714c42
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/AbstractSpringFunctionAdapterInitializer.java
View File

@@ -327,6 +327,12 @@ public abstract class AbstractSpringFunctionAdapterInitializer<C> implements Clo
this.supplier = this.catalog.lookup(Supplier.class, functionName);
return;
}
functionName = this.catalog.getNames(Consumer.class).stream()
.findFirst().orElseGet(() -> null);
if (functionName != null) {
this.consumer = this.catalog.lookup(Consumer.class, functionName);
return;
}
}
else {
name = this.doResolveName(targetContext);