SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix support for binding names for function definitions with comas

Browse Source
This commit is contained in:
Oleg Zhurakousky
2020-09-22 16:42:16 +02:00
parent 3364771da5
commit 66eaef460d
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/BindableFunctionProxyFactory.java
View File

@@ -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)