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

polishing previous commit

Browse Source 
Resolves #2416
This commit is contained in:
Oleg Zhurakousky
2022-06-07 15:09:01 +02:00
parent 862b2003ab
commit cc28eb7c6b
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java
View File

@@ -273,8 +273,9 @@ public final class StreamBridge implements SmartInitializingSingleton {
synchronized MessageChannel resolveDestination(String destinationName, ProducerProperties producerProperties, String binderName) {
MessageChannel messageChannel = null;
if (StringUtils.hasText(binderName)) {
messageChannel = this.channelCache.get(binderName + " " + destinationName);
} else {
messageChannel = this.channelCache.get(binderName + ":" + destinationName);
}
else {
messageChannel = this.channelCache.get(destinationName);
}
if (messageChannel == null) {
@@ -305,8 +306,9 @@ public final class StreamBridge implements SmartInitializingSingleton {
this.bindingService.bindProducer(messageChannel, destinationName, false, binder);
if (StringUtils.hasText(binderName)) {
this.channelCache.put(binderName + " " + destinationName, messageChannel);
} else {
this.channelCache.put(binderName + ":" + destinationName, messageChannel);
}
else {
this.channelCache.put(destinationName, messageChannel);
}
}