From 4e7de96dc9e671159e72f41058fc4945fe050261 Mon Sep 17 00:00:00 2001 From: markfisher Date: Mon, 5 Dec 2016 10:08:02 -0500 Subject: [PATCH] function invoker is conditional on input --- .../cloud/function/stream/StreamConfiguration.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamConfiguration.java b/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamConfiguration.java index ac4500a12..f8beaf81a 100644 --- a/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamConfiguration.java +++ b/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamConfiguration.java @@ -19,6 +19,7 @@ package org.springframework.cloud.function.stream; import java.util.function.Function; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.cloud.function.invoker.AbstractFunctionInvoker; import org.springframework.cloud.function.registry.FileSystemFunctionRegistry; @@ -46,6 +47,7 @@ public class StreamConfiguration { } @Bean + @ConditionalOnProperty("spring.cloud.stream.bindings.input.destination") public AbstractFunctionInvoker invoker(FunctionRegistry registry) { String name = properties.getName(); Function, Flux> function = (name.indexOf(',') == -1) @@ -53,4 +55,5 @@ public class StreamConfiguration { : registry.composeFunction(StringUtils.commaDelimitedListToStringArray(name)); return new StreamListeningFunctionInvoker(function); } + }