@Test
	public void testDestroyTap() {
		HttpSource source = newHttpSource();
		String streamName = generateStreamName();
		String tapName = generateStreamName();
		stream().create(streamName, "%s | log", source);
		stream().create(tapName, "%s > %s", getTapName(streamName), generateQueueName());
		stream().destroyStream(streamName);
		stream().destroyStream(tapName);
	}
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