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

Fixed RoutingFunction ClassCast exception

Browse Source
This commit is contained in:
Oleg Zhurakousky
2019-05-21 08:41:10 -05:00
parent b8c1003309
commit 52b8d67092
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/RoutingFunction.java
View File

@@ -24,7 +24,6 @@ import reactor.core.publisher.SignalType;
import org.springframework.cloud.function.context.FunctionCatalog;
import org.springframework.cloud.function.context.catalog.FunctionInspector;
import org.springframework.cloud.function.core.WrappedFunction;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
import org.springframework.messaging.converter.MessageConverter;
@@ -88,10 +87,10 @@ public class RoutingFunction implements Function<Publisher<Message<?>>, Publishe
}
@SuppressWarnings("rawtypes")
private WrappedFunction getRouteToFunction(Message<?> message) {
private Function getRouteToFunction(Message<?> message) {
String routeToFunctionName = (String) message.getHeaders().get("function.name");
Assert.hasText(routeToFunctionName, "A 'function.name' was not provided as message header.");
WrappedFunction function = functionCatalog.lookup(routeToFunctionName);
Function function = functionCatalog.lookup(routeToFunctionName);
Assert.notNull(function, "Failed to locate function specified with 'function.name':"
+ message.getHeaders().get("function.name"));
return function;