@Test
	public void testDefaultPayloadSerializer() throws Exception {
		RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
		template.setConnectionFactory(connectionFactory);
		template.setKeySerializer(new StringRedisSerializer());
		template.afterPropertiesSet();

		adapter.afterPropertiesSet();
		adapter.start();

		template.boundListOps(currentQueueName).rightPush("message1");
		@SuppressWarnings("unchecked")
		Message<String> message = (Message<String>) messages.poll(1, TimeUnit.SECONDS);
		assertNotNull(message);
		assertEquals("message1", message.getPayload());
	}
Integration test of {@link RedisQueueInboundChannelAdapter}

@author Jennifer Hickey
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/redis/RedisQueueInboundChannelAdapterTests.java