public void assertReceived(URL url, String streamName,
			int msgCountExpected) {
		Assert.notNull(url, "The url should not be null");
		Assert.hasText(streamName, "The streamName can not be empty nor null");
		String request = buildJMXRequest(url, streamName, "*", "*");
		try {
			List<Module> modules = getModuleList(StreamUtils.httpGet(new URL(request)));
			verifySendCounts(modules, msgCountExpected);
		}
		catch (IOException ioException) {
			throw new IllegalStateException(ioException.getMessage(), ioException);
		}
	}
Retrieves the stream and verifies that all modules in the stream processed the data.

@param url The server where the stream is deployed
@param streamName The stream to analyze.
@throws Exception Error processing JSON or making HTTP GET request
spring-xd-integration-test/src/main/java/org/springframework/xd/integration/util/XdEc2Validation.java