@SuppressWarnings("unchecked")
	@Test
	public void testNoSerializer() throws Exception {
		RedisTemplate<String, byte[]> template = new RedisTemplate<String, byte[]>();
		template.setEnableDefaultSerializer(false);
		template.setKeySerializer(new StringRedisSerializer());
		template.setConnectionFactory(connectionFactory);
		template.afterPropertiesSet();

		adapter.setSerializer(null);
		adapter.afterPropertiesSet();
		adapter.start();

		template.boundListOps(currentQueueName).rightPush("message3".getBytes());
		Message<byte[]> message = (Message<byte[]>) messages.poll(1, TimeUnit.SECONDS);
		assertEquals("message3", new String(message.getPayload()));
	}
Integration test of {@link RedisQueueInboundChannelAdapter}

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