@Override
	@After
	public void tearDown() {
		destroyAllJobs();
		waitForEmptyJobList(WAIT_TIME);
	}
Destroys all streams created in the test.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/AbstractJobTest.java