From 4cc66ae0e004a8ae81e6d66073cf0167355eeb86 Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@pivotal.io>
Date: Thu, 26 Oct 2017 10:59:23 -0400
Subject: [PATCH] fixed AbstractBinderTests to take into account previous
 commit '6eff89ca6c4dfc6ae9e0777e5f97e63c45615afc'

---
 .../cloud/stream/binder/AbstractBinderTests.java       | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractBinderTests.java b/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractBinderTests.java
index f68361aa8..b6498ee8e 100644
--- a/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractBinderTests.java
+++ b/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractBinderTests.java
@@ -90,15 +90,15 @@ public abstract class AbstractBinderTests<B extends AbstractTestBinder<? extends
 	public void testClean() throws Exception {
 		Binder binder = getBinder();
 		Binding<MessageChannel> foo0ProducerBinding = binder.bindProducer("foo.0",
-				new DirectChannel(), createProducerProperties());
+				this.createBindableChannel("output", new BindingProperties()), createProducerProperties());
 		Binding<MessageChannel> foo0ConsumerBinding = binder.bindConsumer("foo.0",
-				"testClean", new DirectChannel(), createConsumerProperties());
+				"testClean", this.createBindableChannel("input", new BindingProperties()), createConsumerProperties());
 		Binding<MessageChannel> foo1ProducerBinding = binder.bindProducer("foo.1",
-				new DirectChannel(), createProducerProperties());
+				this.createBindableChannel("output", new BindingProperties()), createProducerProperties());
 		Binding<MessageChannel> foo1ConsumerBinding = binder.bindConsumer("foo.1",
-				"testClean", new DirectChannel(), createConsumerProperties());
+				"testClean", this.createBindableChannel("input", new BindingProperties()), createConsumerProperties());
 		Binding<MessageChannel> foo2ProducerBinding = binder.bindProducer("foo.2",
-				new DirectChannel(), createProducerProperties());
+				this.createBindableChannel("output", new BindingProperties()), createProducerProperties());
 		foo0ProducerBinding.unbind();
 		assertThat(TestUtils
 				.getPropertyValue(foo0ProducerBinding, "lifecycle", Lifecycle.class)