private void setupListener(RedisSerializer<?> listenerSerializer) throws InterruptedException {
		MessageListenerAdapter listener = new MessageListenerAdapter();
		listener.setDelegate(new Listener(latch));
		listener.setSerializer(listenerSerializer);
		listener.afterPropertiesSet();

		this.container = new RedisMessageListenerContainer();
		container.setConnectionFactory(connectionFactory);
		container.afterPropertiesSet();
		container.addMessageListener(listener, Collections.<Topic> singletonList(new ChannelTopic(TOPIC)));
		container.start();
		Thread.sleep(1000);
	}
Temporary copy of SI RedisPublishingMessageHandlerTests that adds tests that publish messages with data types other
than String

@author Mark Fisher
@author Jennifer Hickey
@author Gary Russell
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/redis/RedisPublishingMessageHandlerTests.java