@BeforeClass
	public static void setUp() {
		// Args not required. Just shown as an example.
		// Also, used to pick an unused port
		application = new TestApplicationBootstrap().getSingleNodeApplication().run("--transport", "local");
		integrationSupport = new SingleNodeIntegrationTestSupport(application);
	}
What a Module/Stream developer might write to test a processing chain.

@author David Turanski
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/ExampleProcessingChainTests.java