public void assertReceived(URL containerUrl, String moduleName, String channelName, int msgCountExpected) {
		waitForXD();

		validation.assertReceived(StreamUtils.replacePort(
						containerUrl, xdEnvironment.getJmxPort()),
				STREAM_NAME, moduleName, channelName, msgCountExpected);
	}
Asserts that all channels of the module channel combination, processed the correct number of messages

@param containerUrl the container that is hosting the module
@param moduleName the name of the module jmx element to interrogate.
@param channelName the name of the channel jmx element to interrogate
@param msgCountExpected The number of messages this module and channel should have sent.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/AbstractIntegrationTest.java