@Test
	public void testSimpleStream() throws Exception {
		RedisConnectionFactory connectionFactory = redisAvailableRule.getResource();
		RedisQueueOutboundChannelAdapter adapter = new RedisQueueOutboundChannelAdapter(deployerQueue,
				connectionFactory);
		adapter.setBeanFactory(BusTestUtils.MOCK_BF);
		adapter.setExtractPayload(false);
		adapter.afterPropertiesSet();
		ModuleDescriptor sinkRequest = new ModuleDescriptor.Builder()
				.setGroup("teststream")
				.setModuleDefinition(TestModuleDefinitions.dummy("log", sink))
				.setIndex(1)
				.build();
		Message<?> sinkMessage = MessageBuilder.withPayload(sinkRequest.toString()).build();
		adapter.handleMessage(sinkMessage);
		ModuleDescriptor sourceRequest = new ModuleDescriptor.Builder()
				.setGroup("teststream")
				.setModuleDefinition(TestModuleDefinitions.dummy("time", source))
				.setIndex(0)
				.build();
		Message<?> sourceMessage = MessageBuilder.withPayload(sourceRequest.toString()).build();
		adapter.handleMessage(sourceMessage);
	}
@author Mark Fisher
@author Gary Russell
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/plugins/ModuleDeploymentTests.java