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

Fix AbstractTestBinder

Browse Source
This commit is contained in:
Soby Chacko
2020-05-18 13:44:12 -04:00
parent fe25a2606e
commit 79c8a9e2b0
1 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractTestBinder.java
View File

@@ -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<C extends AbstractBinder<MessageChannel
* org.springframework.cloud.stream.binding.MessageConverterConfigurer
*/
private void checkChannelIsConfigured(MessageChannel messageChannel, CP properties) {
// if (messageChannel instanceof AbstractSubscribableChannel
// && !properties.isUseNativeDecoding()) {
// Assert.isTrue(
// !CollectionUtils
// .isEmpty(((AbstractSubscribableChannel) messageChannel)
// .getChannelInterceptors()),
// "'messageChannel' appears to be misconfigured. "
// + "Consider creating channel via AbstractBinderTest.createBindableChannel(..)");
// }
if (messageChannel instanceof AbstractSubscribableChannel
&& !properties.isUseNativeDecoding()) {
Assert.isTrue(
!CollectionUtils
.isEmpty(((AbstractSubscribableChannel) messageChannel)
.getInterceptors()),
"'messageChannel' appears to be misconfigured. "
+ "Consider creating channel via AbstractBinderTest.createBindableChannel(..)");
}
}
}