public static void destroyAllStreams(final URL adminServer) {
		Assert.notNull(adminServer, "The admin server must be specified.");
		createSpringXDTemplate(adminServer).streamOperations().destroyAll();
	}
Removes all the streams from the cluster. Used to guarantee a clean acceptance test.

@param adminServer The admin server that the command will be executed against.
spring-xd-integration-test/src/main/java/org/springframework/xd/integration/util/StreamUtils.java