@Test
	public void testRabbitSink() {
		String data = UUID.randomUUID().toString();
		RabbitSink rabbitSink = sinks.rabbit(RabbitSource.DEFAULT_QUEUE).addresses(adminServer.getHost() + ":5672");
		stream(rabbitSource + XD_DELIMITER + sinks.file());
		stream(DATA_SENDER_NAME, "trigger --payload='" + data + "'" + XD_DELIMITER + rabbitSink);
		assertValid(data, sinks.file());

	}
Verfies that a message will be dispatched by the rabbit sink and processed by a rabbit source.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/RabbitTest.java