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

minor polishing due to recent change in SCF GH-199

Browse Source
This commit is contained in:
Oleg Zhurakousky
2018-08-15 20:26:59 +02:00
parent c8bd515e71
commit 844ff3230e
1 changed files with 2 additions and 2 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/FunctionInvoker.java
View File

@@ -53,8 +53,8 @@ class FunctionInvoker<I, O> implements Function<Flux<Message<I>>, Flux<Message<O
FunctionInvoker(String functionName, FunctionCatalog functionCatalog, FunctionInspector functionInspector,
CompositeMessageConverterFactory compositeMessageConverterFactory) {
this.userFunction = functionCatalog.lookup(Function.class, functionName);
this.userFunction = functionCatalog.lookup(functionName);
Assert.isInstanceOf(Function.class, this.userFunction);
Assert.notNull(this.userFunction, "userFunction: " + functionName + " can not be located.");
this.messageConverter = compositeMessageConverterFactory.getMessageConverterForAllRegistered();
FunctionType functionType = functionInspector.getRegistration(this.userFunction).getType();