diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/MessageRoutingCallback.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/MessageRoutingCallback.java index 75aa71bb0..137d2b859 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/MessageRoutingCallback.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/MessageRoutingCallback.java @@ -16,8 +16,6 @@ package org.springframework.cloud.function.context; -import org.reactivestreams.Publisher; - import org.springframework.messaging.Message; /** @@ -27,13 +25,5 @@ import org.springframework.messaging.Message; */ public interface MessageRoutingCallback { - default String route(Message message, FunctionProperties functionProperties) { - // noop - return null; - } - - default String route(Publisher publisher, FunctionProperties functionProperties) { - //noop - return null; - } + String route(Message message, FunctionProperties functionProperties); } 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 319d89c42..d98929f1b 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 @@ -179,12 +179,6 @@ public class RoutingFunction implements Function { return this.functionFromDefinition(functionDefinition); } } - else { - String functionDefinition = this.routingCallback.route((Publisher) input, this.functionProperties); - if (StringUtils.hasText(functionDefinition)) { - return this.functionFromDefinition(functionDefinition); - } - } return null; }