public NamedChannelSource createNamedChannelSource(String channelName) {
		validateChannelName(channelName);
		if (channelName.startsWith(QUEUE_PREFIX)) {
			return new SingleNodeNamedQueueSource(this.messageBus, channelName);
		}
		return new SingleNodeNamedTopicSource(this.messageBus, channelName);
	}
A factory for creating {@link NamedChannelSource}s.

@author David Turanski
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/test/source/SingleNodeNamedChannelSourceFactory.java