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)