@Test
	public void moduleDeploymentPropertiesForModuleLabel() throws InterruptedException {
		String streamName = "moduleDeploymentPropertiesForModuleLabel";
		String dsl = String.format("http --port=%s | t1: transform | t2: transform | log",
				SocketUtils.findAvailableServerSocket());
		StreamDefinition definition = new StreamDefinition(streamName, dsl);
		integrationSupport.streamDeployer().save(definition);
		Map<String, String> props = new HashMap<String, String>();
		props.put("module.t1.prop1", "0");
		props.put("module.t1.other", "foo");
		props.put("module.t2.other", "bar");
		assertTrue("Timeout waiting for stream deployment", integrationSupport.deployStream(definition, props));
		Module t1 = integrationSupport.getModule(streamName, "t1", 1);
		ModuleDeploymentProperties t1Props = t1.getDeploymentProperties();
		assertEquals("0", t1Props.get("prop1"));
		assertEquals("foo", t1Props.get("other"));
		Module t2 = integrationSupport.getModule(streamName, "t2", 2);
		ModuleDeploymentProperties t2Props = t2.getDeploymentProperties();
		assertEquals("1", t2Props.get("count"));
		assertEquals("bar", t2Props.get("other"));
		integrationSupport.undeployAndDestroyStream(definition);
		Thread.sleep(2000); // todo: we need waitForDestroy within the previous method
	}
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