diff --git a/spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java b/spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java index 357872dedd..b79f5373b9 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java @@ -146,7 +146,7 @@ public class MessageBus implements ChannelRegistry, ApplicationContextAware, Lif } if (this.autoCreateChannels) { String defaultOutputChannelName = endpoint.getDefaultOutputChannelName(); - if (StringUtils.hasText(defaultOutputChannelName)) { + if (StringUtils.hasText(defaultOutputChannelName) && this.lookupChannel(defaultOutputChannelName) == null) { this.registerChannel(defaultOutputChannelName, new PointToPointChannel()); } }