@Override
			public void test(Message<?> message) throws MessagingException {
				assertEquals("foo2", message.getPayload());
			}
Tests for streams created with composed modules.

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