@Test
	public void testRabbitSource() {
		String data = UUID.randomUUID().toString();
		stream(rabbitSource + XD_DELIMITER + sinks.file());
		rabbitSource.sendData(data);
		assertValid(data, sinks.file());
	}
Verfies that a message dispatched to a queue can be picked up and properly processed by the Rabbit Source.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/RabbitTest.java