@Test
	public void testProcessor() throws Exception {
		RedisConnectionFactory connectionFactory = redisAvailableRule.getResource();
		RedisQueueOutboundChannelAdapter adapter = new RedisQueueOutboundChannelAdapter(deployerQueue,
				connectionFactory);
		adapter.setBeanFactory(BusTestUtils.MOCK_BF);
		adapter.setExtractPayload(false);
		adapter.afterPropertiesSet();
		ModuleDescriptor request = new ModuleDescriptor.Builder()
				.setGroup("test")
				.setModuleDefinition(TestModuleDefinitions.dummy("filter", processor))
				.setIndex(0)
				.build();
		Message<?> message = MessageBuilder.withPayload(request.toString()).build();
		adapter.handleMessage(message);
	}
@author Mark Fisher
@author Gary Russell
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/plugins/ModuleDeploymentTests.java