@Test
	public void testInvalidDeploymentPropertiesShouldUseLabel() {
		StreamDefinition testStream = new StreamDefinition("foo", "http | bar: log");
		integrationSupport.streamDeployer().save(testStream);

		thrown.expect(IllegalArgumentException.class);
		thrown.expectMessage(containsString("module.log.count"));

		Map<String, String> properties = Collections.singletonMap("module.log.count", "3");
		integrationSupport.deployStream(testStream, properties);
	}
Test class to validate the deployment behavior that need not be tested across transports.  

@author Eric Bottard
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/DeployerTests.java