public static void stream(final String streamName, final String streamDefinition,
			final URL adminServer) {
		Assert.hasText(streamName, "The stream name must be specified.");
		Assert.hasText(streamDefinition, "a stream definition must be supplied.");
		Assert.notNull(adminServer, "The admin server must be specified.");
		createSpringXDTemplate(adminServer).streamOperations().createStream(streamName, streamDefinition, true);
	}
Creates the stream definition and deploys it to the cluster being tested.

@param streamName The name of the stream
@param streamDefinition The definition that needs to be deployed for this stream.
@param adminServer The admin server that this stream will be deployed against.
spring-xd-integration-test/src/main/java/org/springframework/xd/integration/util/StreamUtils.java