@Before
	public void initialize() {
		rabbitSource = sources.rabbitSource();
		rabbitSource.ensureReady();
		rabbitSource.createQueue();
	}
Verifies connectivity to the broker instance and creates the queue for the test.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/RabbitTest.java