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

GH-2106 re-enable '.destination' and made destination channel PubSub

Browse Source 
Resolves #2106
This commit is contained in:
Oleg Zhurakousky
2021-03-26 08:24:54 +01:00
parent 561ae852c3
commit d1488259a6
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/TestChannelBinderProvisioner.java
View File

@@ -85,7 +85,7 @@ public class TestChannelBinderProvisioner
SubscribableChannel destination = this.provisionedDestinations
.get(destinationName);
if (destination == null) {
destination = pubSub ? new PublishSubscribeChannel() : new DirectChannel();
destination = new PublishSubscribeChannel();
((AbstractMessageChannel) destination).setBeanName(destinationName);
((AbstractMessageChannel) destination).setComponentName(destinationName);
this.provisionedDestinations.put(destinationName, destination);