protected void assertModuleRequest(String streamName, String moduleName, boolean remove) {
		PathChildrenCacheEvent event = remove ? deploymentsListener.nextUndeployEvent(streamName)
				: deploymentsListener.nextDeployEvent(streamName);
		assertNotNull(String.format("deploymentsListener returned a null event for stream %s, module %s",
				streamName, moduleName), event);
		assertTrue(moduleName + " not found in " + event.getData().getPath() + " (remove = " + remove + ")",
				event.getData().getPath().contains(moduleName));
	}
Verifies the content of the queues

@param y3 the channel where the y's are sent
@param z3 the channel where the z's are sent
@param initialTransportState the initial state of the transport (can be ignored except for Kafka)
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/AbstractSingleNodeStreamDeploymentIntegrationTests.java