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

		adapter.setExtractPayload(false);
		adapter.afterPropertiesSet();

		Map<String, Object> headers = new HashMap<String, Object>();
		headers.put("header1", "foo");
		adapter.handleMessage(new GenericMessage<String>("message2", headers));
		Message<?> message = template.boundListOps(QUEUE_NAME).rightPop();
		assertEquals("message2", message.getPayload());
		assertEquals("foo", message.getHeaders().get("header1"));
	}
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