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 f6e24e141..6ac6de5ed 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 @@ -19,7 +19,10 @@ package org.springframework.cloud.stream.binder; import java.util.HashSet; import java.util.Set; +import org.springframework.integration.channel.AbstractSubscribableChannel; import org.springframework.messaging.MessageChannel; +import org.springframework.util.Assert; +import org.springframework.util.CollectionUtils; /** * Abstract class that adds test support for {@link Binder}. @@ -83,15 +86,15 @@ public abstract class AbstractTestBinder