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

		adapter.setExpectMessage(true);
		adapter.afterPropertiesSet();
		adapter.start();

		Map<String, Object> headers = new HashMap<String, Object>();
		headers.put("header1", "foo");
		template.boundListOps(currentQueueName).rightPush(new GenericMessage<String>("message2", headers));
		@SuppressWarnings("unchecked")
		Message<String> message = (Message<String>) messages.poll(1, TimeUnit.SECONDS);
		assertEquals("message2", message.getPayload());
		assertEquals("foo", message.getHeaders().get("header1"));
	}
Integration test of {@link RedisQueueInboundChannelAdapter}

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