From 2bc8404f224e6b7d238d0e02840b18ea0837e38f Mon Sep 17 00:00:00 2001 From: David Turanski Date: Sun, 27 Sep 2020 12:14:37 -0400 Subject: [PATCH] Throw exception on invalid function definition Resolves #2022 --- .../cloud/stream/function/FunctionConfiguration.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java index c68c17108..115576b4d 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java @@ -711,6 +711,10 @@ public class FunctionConfiguration { functionBindableProxyDefinition.getConstructorArgumentValues().addGenericArgumentValue(this.streamFunctionProperties); registry.registerBeanDefinition(functionDefinition + "_binding", functionBindableProxyDefinition); } + else { + throw new IllegalArgumentException("The function definition '" + streamFunctionProperties.getDefinition() + + "' is not valid. The referenced function bean or one of its components does not exist"); + } } }