diff --git a/spring-integration-core/src/main/java/org/springframework/integration/router/AbstractMappingMessageRouter.java b/spring-integration-core/src/main/java/org/springframework/integration/router/AbstractMappingMessageRouter.java index ee20673889..26c679a77c 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/router/AbstractMappingMessageRouter.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/router/AbstractMappingMessageRouter.java @@ -288,6 +288,9 @@ public abstract class AbstractMappingMessageRouter extends AbstractMessageRouter } private void addToCollection(Collection channels, Collection channelKeys, Message message) { + if (channelKeys == null) { + return; + } for (Object channelKey : channelKeys) { if (channelKey instanceof MessageChannel) { channels.add((MessageChannel) channelKey);