From 9db5f64a702d57db4bd015e7deba44331cd21c04 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Tue, 12 Nov 2019 18:59:34 +0100 Subject: [PATCH] Initial fix for binding name of composed functions --- .../cloud/stream/function/BindableFunctionProxyFactory.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/BindableFunctionProxyFactory.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/BindableFunctionProxyFactory.java index 8ec010359..2d9b2631e 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/BindableFunctionProxyFactory.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/BindableFunctionProxyFactory.java @@ -108,7 +108,7 @@ class BindableFunctionProxyFactory extends BindableProxyFactory { } private String buildInputNameForIndex(int index) { - return new StringBuilder(this.functionDefinition) + return new StringBuilder(this.functionDefinition.replace("|", "")) .append(FunctionConstants.DELIMITER) .append(FunctionConstants.DEFAULT_INPUT_SUFFIX) .append(FunctionConstants.DELIMITER) @@ -117,7 +117,7 @@ class BindableFunctionProxyFactory extends BindableProxyFactory { } private String buildOutputNameForIndex(int index) { - return new StringBuilder(this.functionDefinition) + return new StringBuilder(this.functionDefinition.replace("|", "")) .append(FunctionConstants.DELIMITER) .append(FunctionConstants.DEFAULT_OUTPUT_SUFFIX) .append(FunctionConstants.DELIMITER)