From d1488259a66e18e78d201a5260626b37aa91fbdb Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Fri, 26 Mar 2021 08:24:54 +0100 Subject: [PATCH] GH-2106 re-enable '.destination' and made destination channel PubSub Resolves #2106 --- .../cloud/stream/binder/test/TestChannelBinderProvisioner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/TestChannelBinderProvisioner.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/TestChannelBinderProvisioner.java index 7c91a21ac..3a20a1c81 100644 --- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/TestChannelBinderProvisioner.java +++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/TestChannelBinderProvisioner.java @@ -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);