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 d892822eea..156dc36c5a 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 @@ -38,6 +38,7 @@ import org.springframework.integration.channel.DefaultChannelRegistry; import org.springframework.integration.endpoint.MessageEndpoint; import org.springframework.integration.message.Message; import org.springframework.util.Assert; +import org.springframework.util.StringUtils; /** * The messaging bus. Serves as a registry for channels and endpoints, manages their lifecycle, @@ -143,6 +144,12 @@ public class MessageBus implements ChannelRegistry, ApplicationContextAware, Lif subscription.setPolicy(endpoint.getConsumerPolicy()); this.activateSubscription(subscription); } + if (this.autoCreateChannels) { + String defaultOutputChannelName = endpoint.getDefaultOutputChannelName(); + if (StringUtils.hasText(defaultOutputChannelName)) { + this.registerChannel(defaultOutputChannelName, new PointToPointChannel()); + } + } } public void activateSubscription(Subscription subscription) {