public void assertReceived(URL url, String streamName,
			String moduleName, String channelName, int msgCountExpected) {
		Assert.notNull(url, "The url should not be null");
		Assert.hasText(moduleName, "The modulName can not be empty nor null");
		Assert.hasText(streamName, "The streamName can not be empty nor null");
		Assert.hasText(channelName, "The channelName can not be empty nor null");
		String request = buildJMXRequest(url, streamName, moduleName, channelName);
		try {
			Module module = getModule(StreamUtils.httpGet(new URL(request)));
			assertEquals("Module "
					+ moduleName + " for channel " + channelName
					+ " did not have expected count ", msgCountExpected, Integer.parseInt(module.getSendCount()));

		}
		catch (IOException ioException) {
			throw new IllegalStateException(ioException.getMessage(), ioException);
		}

	}
Verifies that the instances for the channel and module has in fact processed the correct number of messages. Keep
in mind that any module name must be suffixed with index number for example .1. So if I have a stream of
http|file, to access the modules I will need to have a module name of http.1 for the source and file.1 for the
sink.

@param url The server where the stream is deployed
@param streamName The stream to analyze.
@param moduleName The name of the module.
@param channelName The name of the channel to interrogate.
@param msgCountExpected expected number of messages to have been successfully processed by the module.
spring-xd-integration-test/src/main/java/org/springframework/xd/integration/util/XdEc2Validation.java