diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java index 6b966fd75..d00b95a9c 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java @@ -267,8 +267,8 @@ public abstract class AbstractMessageChannelBinder 1 && getBindingServiceProperties().getDefaultBinder() != null) { return getBindingServiceProperties().getDefaultBinder(); } - Assert.isTrue(binderTypes.entrySet().size() == 1, "More than one binder types found, but no binder specified on the binding"); - return binderTypes.keySet().iterator().next(); + Assert.isTrue(binderTypes.entrySet().size() <= 1, "More than one binder types found, but no binder specified on the binding"); + return (binderTypes.entrySet().size() < 1) ? null : binderTypes.keySet().iterator().next(); } /**