@Test
	public void testCreateNamedChannelAsSource() throws InterruptedException {
		String streamName1 = generateStreamName();
		String streamName2 = generateStreamName();
		String queueName = generateQueueName();
		logger.info("Creating stream with named channel '" + queueName + "' as source");
		HttpSource httpSource = newHttpSource();
		CounterSink counterSink = metrics().newCounterSink();

		stream().create(streamName1, "%s | transform --expression=payload.toUpperCase() > %s",
				httpSource, queueName);
		// Create stream with named channel as source
		stream().create(streamName2, "%s > %s", queueName, counterSink);
		httpSource.ensureReady().postData("test");
		assertThat(counterSink, eventually(hasValue("1")));
	}
Tests for named channels.

@author Ilayaperumal Gopinathan
@author Eric Bottard
@author Andy Clement
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractNamedChannelTests.java