diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/FunctionRegistration.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/FunctionRegistration.java index 257aa6997..07919b89f 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/FunctionRegistration.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/FunctionRegistration.java @@ -24,6 +24,8 @@ import java.util.LinkedHashSet; import java.util.Map; import java.util.Set; +import org.springframework.util.Assert; + import reactor.core.publisher.Flux; /** @@ -42,6 +44,7 @@ public class FunctionRegistration { private FunctionType type; public FunctionRegistration(T target) { + Assert.notNull(target, "'target' must not be null"); this.target = target; }