@Test
	public void testCustomMessageSerializer() throws Exception {
		RedisTemplate<String, Message<?>> template = new RedisTemplate<String, Message<?>>();
		template.setKeySerializer(new StringRedisSerializer());
		template.setValueSerializer(new TestMessageSerializer());
		template.setConnectionFactory(connectionFactory);
		template.afterPropertiesSet();

		adapter.setSerializer(new TestMessageSerializer());
		adapter.setExpectMessage(true);
		adapter.afterPropertiesSet();
		adapter.start();

		template.boundListOps(currentQueueName).rightPush(new GenericMessage<Long>(10l));
		@SuppressWarnings("unchecked")
		Message<Long> message = (Message<Long>) messages.poll(1, TimeUnit.SECONDS);
		assertEquals(10L, (long) message.getPayload());
	}
Integration test of {@link RedisQueueInboundChannelAdapter}

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