diff --git a/applications/source/file-source/pom.xml b/applications/source/file-source/pom.xml index b9aa94eb..40ff361a 100644 --- a/applications/source/file-source/pom.xml +++ b/applications/source/file-source/pom.xml @@ -59,12 +59,6 @@ org.springframework.cloud.stream.app stream-applications-composite-function-support ${stream-apps-core.version} - - - org.springframework.cloud.fn - splitter-function - - diff --git a/applications/stream-applications-core/common/stream-applications-composite-function-support/pom.xml b/applications/stream-applications-core/common/stream-applications-composite-function-support/pom.xml index 1d7306cd..058617d2 100644 --- a/applications/stream-applications-core/common/stream-applications-composite-function-support/pom.xml +++ b/applications/stream-applications-core/common/stream-applications-composite-function-support/pom.xml @@ -51,11 +51,6 @@ payload-converter-function ${java-functions.version} - - org.springframework.cloud.fn - splitter-function - ${java-functions.version} - org.springframework.cloud.fn task-launch-request-function diff --git a/functions/function/splitter-function/src/main/java/org/springframework/cloud/fn/splitter/SplitterFunctionConfiguration.java b/functions/function/splitter-function/src/main/java/org/springframework/cloud/fn/splitter/SplitterFunctionConfiguration.java index 11f3e3b6..f8adff49 100644 --- a/functions/function/splitter-function/src/main/java/org/springframework/cloud/fn/splitter/SplitterFunctionConfiguration.java +++ b/functions/function/splitter-function/src/main/java/org/springframework/cloud/fn/splitter/SplitterFunctionConfiguration.java @@ -45,7 +45,7 @@ public class SplitterFunctionConfiguration { @Bean public Function, List>> splitterFunction(AbstractMessageSplitter messageSplitter, - SplitterFunctionProperties splitterFunctionProperties) { + SplitterFunctionProperties splitterFunctionProperties) { messageSplitter.setApplySequence(splitterFunctionProperties.isApplySequence()); ThreadLocalFluxSinkMessageChannel outputChannel = new ThreadLocalFluxSinkMessageChannel(); @@ -80,7 +80,6 @@ public class SplitterFunctionConfiguration { return fileSplitter; } - @Bean @ConditionalOnMissingBean public AbstractMessageSplitter defaultSplitter(SplitterFunctionProperties splitterFunctionProperties) { diff --git a/functions/function/splitter-function/src/main/resources/META-INF/spring.factories b/functions/function/splitter-function/src/main/resources/META-INF/spring.factories deleted file mode 100644 index cf51183f..00000000 --- a/functions/function/splitter-function/src/main/resources/META-INF/spring.factories +++ /dev/null @@ -1,2 +0,0 @@ -org.springframework.boot.autoconfigure.EnableAutoConfiguration=\ - org.springframework.cloud.fn.splitter.SplitterFunctionConfiguration