@Test
	public void testRegistration() throws Exception {
		streamPlugin.postProcessModule(module);
		verify(bus).bindConsumer(eq("mystream.0"), same(input), any(Properties.class));
		verify(bus).bindProducer(eq("mystream.1"), same(output), any(Properties.class));
		assertNotNull(consumerProperties);
		assertEquals(1, consumerProperties.size());
		assertEquals("bar", consumerProperties.get("foo"));
		assertNotNull(producerProperties);
		assertEquals(1, producerProperties.size());
		assertEquals("qux", producerProperties.get("baz"));
	}
@author Jennifer Hickey
@author Gary Russell
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/plugins/stream/MessageBusRegistrationTests.java