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

fix compiled consumer sample

Browse Source
This commit is contained in:
markfisher
2017-05-25 09:27:49 -04:00
parent c685866f09
commit 841d4cdf48
3 changed files with 64 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/ContextFunctionCatalogAutoConfiguration.java
View File

@@ -424,7 +424,7 @@ public class ContextFunctionCatalogAutoConfiguration {
}
else {
// TODO: compiled functions (only work as String -> String)
if (paramType.isWrapper()) {
if (paramType.isWrapper() && !Consumer.class.isAssignableFrom(definition.getBeanClass())) {
return Flux.class;
}
return String.class;