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

fixed AbstractBinderTests to take into account previous commit '6eff89ca6c4dfc6ae9e0777e5f97e63c45615afc'

Browse Source
This commit is contained in:
Oleg Zhurakousky
2017-10-26 10:59:23 -04:00
parent 6eff89ca6c
commit 4cc66ae0e0
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractBinderTests.java
View File

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