private void setupMessageListener(CountDownLatch latch, String topic) throws InterruptedException {
		MessageListenerAdapter listener = new MessageListenerAdapter();
		listener.setDelegate(new Listener(latch));
		listener.afterPropertiesSet();

		this.container = new RedisMessageListenerContainer();
		container.setConnectionFactory(this.redisAvailableRule.getResource());
		container.afterPropertiesSet();
		container.addMessageListener(listener, Collections.<Topic> singletonList(new ChannelTopic(topic)));
		container.start();
		Thread.sleep(1000);
	}
Integration tests for Redis sink.

@author Ilayaperumal Gopinathan
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractRedisSinkTests.java