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