@Test
	public void testProcessorLinkingChannels() throws Exception {
		FileSink sink = newFileSink().binary(true);
		HttpSource source = newHttpSource(9314);

		String streamName0 = generateStreamName();
		String streamName1 = generateStreamName();
		String streamName2 = generateStreamName();

		String queue1 = generateQueueName();
		String queue2 = generateQueueName();

		stream().create(streamName0, "%s > %s", source, queue1);
		stream().create(streamName1, "%s > transform --expression=payload.toUpperCase() > %s", queue1, queue2);
		stream().create(streamName2, "%s > %s", queue2, sink);

		source.postData("blahblah");

		assertThat(String.format("Assert failed for streams %s, %s, %s", streamName0, streamName1, streamName2),
				sink, eventually(hasContentsThat(equalTo("BLAHBLAH"))));
	}
Test a stream that is simply one processor module connecting two named channels.
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractStreamCommandsTests.java