diff --git a/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractTestBinder.java b/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractTestBinder.java index 1cab5e15e..46f8e6041 100644 --- a/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractTestBinder.java +++ b/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractTestBinder.java @@ -43,7 +43,7 @@ public abstract class AbstractTestBinder bindConsumer(String name, String group, MessageChannel moduleInputChannel, CP properties) { - this.checkChannelIsConfigured(moduleInputChannel); + this.checkChannelIsConfigured(moduleInputChannel, properties); queues.add(name); return binder.bindConsumer(name, group, moduleInputChannel, properties); } @@ -79,8 +79,8 @@ public abstract class AbstractTestBinder