private String buildStreamDefinition(String processingChain) {
		StringBuilder sb = new StringBuilder();
		if (createSource()) {
			sb.append(QUEUE_PRODUCER).append(">");
		}
		sb.append(processingChain);
		if (createSink()) {
			sb.append(">").append(QUEUE_CONSUMER);
		}
		return sb.toString();
	}
A helper class for building single node streams that use a {@link NamedChannelSource} and {@link NamedChannelSink}.

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