Fix AbstractMappingMessageRouter for NPE

2020-01-24 19:17:08 -05:00
parent d2df9dde9f
commit 990294b048
1 changed files with 3 additions and 0 deletions
--- 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<MessageChannel> channels, Collection<?> channelKeys, Message<?> message) {
+		if (channelKeys == null) {
+			return;
+		}
 		for (Object channelKey : channelKeys) {
 			if (channelKey instanceof MessageChannel) {
 				channels.add((MessageChannel) channelKey);