Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Sonar issues

Browse Source
This commit is contained in:
Gary Russell
2019-07-31 09:40:54 -04:00
parent 884db2c609
commit f7fc3360cd
5 changed files with 31 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
spring-integration-core/src/main/java/org/springframework/integration/router/AbstractMappingMessageRouter.java
View File

@@ -264,18 +264,25 @@ public abstract class AbstractMappingMessageRouter extends AbstractMessageRouter
mapped = true;
}
if (channelName != null) {
if (this.prefix != null) {
channelName = this.prefix + channelName;
}
if (this.suffix != null) {
channelName = channelName + this.suffix;
}
MessageChannel channel = resolveChannelForName(channelName, message);
if (channel != null) {
channels.add(channel);
if (!mapped && this.dynamicChannels.get(channelName) == null) {
this.dynamicChannels.put(channelName, channel);
}
addChannel(channels, message, channelName, mapped);
}
}
private void addChannel(Collection<MessageChannel> channels, Message<?> message, String channelNameArg,
boolean mapped) {
String channelName = channelNameArg;
if (this.prefix != null) {
channelName = this.prefix + channelName;
}
if (this.suffix != null) {
channelName = channelName + this.suffix;
}
MessageChannel channel = resolveChannelForName(channelName, message);
if (channel != null) {
channels.add(channel);
if (!mapped && this.dynamicChannels.get(channelName) == null) {
this.dynamicChannels.put(channelName, channel);
}
}
}