@Test
	public void moduleChannelsRegisteredWithMessageBus() throws InterruptedException {
		StreamDefinition sd = new StreamDefinition("busTest", getHttpLogStream());
		int originalBindings = getMessageBusBindingCount();
		assertTrue("Timeout waiting for stream deployment", integrationSupport.createAndDeployStream(sd));
		int newBindings = getMessageBusBindingCount() - originalBindings;
		assertEquals(2, newBindings);

		StreamDefinition tapStream = new StreamDefinition("busTestTap", "tap:stream:busTest > log");
		assertTrue("Timeout waiting for stream deployment", integrationSupport.createAndDeployStream(tapStream));
		int afterTapBindings = getMessageBusBindingCount() - originalBindings;
		assertEquals(4, afterTapBindings);
		integrationSupport.undeployAndDestroyStream(tapStream);
		integrationSupport.undeployAndDestroyStream(sd);
		Thread.sleep(2000); // todo: we need waitForDestroy within the previous method
		assertEquals(originalBindings, getMessageBusBindingCount());
	}
Get the stream 'http | log' with random available http port selected.

@return the stream
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/AbstractSingleNodeStreamDeploymentIntegrationTests.java