@Test
	public void testStreamWithCompositeSource() {
		deployStream("streamWithCompositeSource", "compositesource | sink");
		MessageTest test = new MessageTest() {

			@Override
			public void test(Message<?> message) throws MessagingException {
				assertEquals("foo1", message.getPayload());
			}
		};
		sendPayloadAndVerifyOutput("streamWithCompositeSource", "foo", test);
		// Delete the stream definition
		deleteStream("streamWithCompositeSource");
	}
Tests for streams created with composed modules.

@author Mark Fisher
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/ComposedModuleStreamTests.java