@Before
	public void setup() {
		initializer();
		StreamUtils.destroyAllStreams(adminServer);
		waitForXD();
	}
Destroys all streams in the xd cluster and calls initializer.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/AbstractIntegrationTest.java