@Test
	public void directBindingNotEnabledWithOverriddenCount() throws InterruptedException {
		String streamName = "directBindingNotEnabledWithOverriddenCount";
		StreamDefinition sd = new StreamDefinition(streamName, "http | log");
		integrationSupport.streamDefinitionRepository().save(sd);
		Map<String, String> props = new HashMap<String, String>();
		props.put("module.*.count", "0");
		props.put("module.log.count", "3");
		integrationSupport.deployStream(sd, props,/*allowIncomplete*/true);
		List<Binding> bindings = getMessageBusBindingsForStream(streamName);
		assertEquals(2, bindings.size());
		Binding consumerBinding = bindings.get(0);
		Binding producerBinding = bindings.get(1);
		assertEquals("consumer", consumerBinding.getType());
		assertEquals("producer", producerBinding.getType());
	}
Base class for testing non-local transports, such as RabbitMQ and Redis.

@author Mark Fisher
@author Gary Russell
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/AbstractDistributedTransportSingleNodeStreamDeploymentIntegrationTests.java