From a82655548c31f75abf7037884456d0967bcd22fe Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Tue, 18 Dec 2007 16:31:02 +0000
Subject: [PATCH] Auto-creating default output channels.

---
 .../org/springframework/integration/bus/MessageBus.java    | 7 +++++++
 1 file changed, 7 insertions(+)

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) {