@Override
	protected void verifyOnDemandQueues(MessageChannel y3, MessageChannel z3, Map<String, Object> initialTransportState) {
		RabbitTemplate template = new RabbitTemplate(rabbitAvailableRule.getResource());
		Object y = template.receiveAndConvert("xdbus.queue:y");
		assertNotNull(y);
		assertEquals("y", y);
		Object z = template.receiveAndConvert("xdbus.queue:z");
		assertNotNull(z);
		assertEquals("z", z);
	}
@author Mark Fisher
@author Gary Russell
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/RabbitSingleNodeStreamDeploymentIntegrationTests.java