@Test
	public void testWithDefaultSerializer() throws Exception {
		setupListener(new StringRedisSerializer());
		final RedisPublishingMessageHandler handler = new RedisPublishingMessageHandler(connectionFactory);
		handler.setBeanFactory(BusTestUtils.MOCK_BF);
		handler.setTopic(TOPIC);
		handler.afterPropertiesSet();
		for (int i = 0; i < NUM_MESSAGES; i++) {
			handler.handleMessage(MessageBuilder.withPayload("test-" + i).build());
		}
		latch.await(3, TimeUnit.SECONDS);
		assertEquals(0, latch.getCount());
		container.stop();
	}
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