@Test
	public void testUsingPlaceholdersInsideStreamDefinition() {
		String streamName = generateStreamName();
		HttpSource source = newHttpSource();
		FileSink sink = newFileSink().binary(true);

		stream().create(streamName, "%s | transform --expression=\"'${xd.stream.name}'\" | %s", source, sink);

		source.ensureReady().postData("whatever");
		assertThat(sink, eventually(hasContentsThat(equalTo(streamName))));
	}
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