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

Initial fix for binding name of composed functions

Browse Source
This commit is contained in:
Oleg Zhurakousky
2019-11-12 18:59:34 +01:00
parent 0d9982fddb
commit 9db5f64a70
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

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