From 66eaef460db97e99a01154872aa3b672a3629eda Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Tue, 22 Sep 2020 16:42:16 +0200 Subject: [PATCH] Fix support for binding names for function definitions with comas --- .../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 bb687efb7..fb3e5f550 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 @@ -112,7 +112,7 @@ class BindableFunctionProxyFactory extends BindableProxyFactory { } private String buildInputNameForIndex(int index) { - return new StringBuilder(this.functionDefinition.replace("|", "")) + return new StringBuilder(this.functionDefinition.replace(",", "|").replace("|", "")) .append(FunctionConstants.DELIMITER) .append(FunctionConstants.DEFAULT_INPUT_SUFFIX) .append(FunctionConstants.DELIMITER) @@ -121,7 +121,7 @@ class BindableFunctionProxyFactory extends BindableProxyFactory { } private String buildOutputNameForIndex(int index) { - return new StringBuilder(this.functionDefinition.replace("|", "")) + return new StringBuilder(this.functionDefinition.replace(",", "|").replace("|", "")) .append(FunctionConstants.DELIMITER) .append(FunctionConstants.DEFAULT_OUTPUT_SUFFIX) .append(FunctionConstants.DELIMITER)