@After
	public void after() throws InterruptedException {
		distributedTestSupport.ensureTemplate().streamOperations().destroyAll();
		distributedTestSupport.ensureTemplate().jobOperations().destroyAll();
		distributedTestSupport.shutdownContainers();
	}
After each test execution, all containers are shut down
and all streams/jobs destroyed.
spring-xd-distributed-test/src/test/java/org/springframework/xd/distributed/test/AbstractDistributedTests.java