public NamedChannelSink createNamedChannelSink(String channelName) {
		validateChannelName(channelName);
		if (channelName.startsWith(QUEUE_PREFIX)) {
			return new SingleNodeNamedQueueSink(this.messageBus, channelName);
		}
		return new SingleNodeNamedTopicSink(this.messageBus, channelName);

	}
A factory for creating {@link NamedChannelSink}s.

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