diff --git a/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/FunctionController.java b/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/FunctionController.java index 9bab7aabd..c0aabcdfa 100644 --- a/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/FunctionController.java +++ b/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/FunctionController.java @@ -59,8 +59,11 @@ public class FunctionController { return debug ? result.log() : result; } Consumer consumer = functions.lookupConsumer(name); - body.subscribe(consumer::accept); - return null; + if (consumer != null) { + body.subscribe(consumer::accept); + return null; + } + throw new IllegalArgumentException("no such function: " + name); } @GetMapping(path = "/{name}")