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

Auto-creating default output channels.

Browse Source
This commit is contained in:
Mark Fisher
2007-12-18 16:31:02 +00:00
parent e174a9222a
commit a82655548c
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-integration-core/src/main/java/org/springframework/integration/bus/MessageBus.java
View File

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