@Test
	public void testCustomPayloadSerializer() throws Exception {
		RedisTemplate<String, Long> template = new RedisTemplate<String, Long>();
		template.setKeySerializer(new StringRedisSerializer());
		template.setValueSerializer(new GenericToStringSerializer<Long>(Long.class));
		template.setConnectionFactory(connectionFactory);
		template.afterPropertiesSet();

		adapter.setSerializer(new GenericToStringSerializer<Long>(Long.class));
		adapter.afterPropertiesSet();

		adapter.handleMessage(new GenericMessage<Long>(5l));
		assertEquals(Long.valueOf(5), template.boundListOps(QUEUE_NAME).rightPop());
	}
Integration test of {@link RedisQueueOutboundChannelAdapter}

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