From 52b8d67092a8fc76a3cd0d8e9c7a9d13a546151c Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Tue, 21 May 2019 08:41:10 -0500 Subject: [PATCH] Fixed RoutingFunction ClassCast exception --- .../cloud/function/context/config/RoutingFunction.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/RoutingFunction.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/RoutingFunction.java index fe1524b32..e80c6126a 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/RoutingFunction.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/RoutingFunction.java @@ -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>, 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;