@Override
	protected void verifyOnDemandQueues(MessageChannel y3, MessageChannel z3, Map<String, Object> initialTransportState) {
		StringRedisTemplate template = new StringRedisTemplate(redisAvailableRule.getResource());
		String y = template.boundListOps("queue.queue:y").rightPop();
		assertNotNull(y);
		assertTrue(y.endsWith("y")); // bus headers
		String z = template.boundListOps("queue.queue:z").rightPop();
		assertNotNull(z);
		assertTrue(z.endsWith("z")); // bus headers
	}
@author Mark Fisher
@author Gary Russell
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/RedisSingleNodeStreamDeploymentIntegrationTests.java