@After
	public void cleanup() {
		// Need to undeploy stream before destroying queue or the source will throw exceptions when the queue is
		// destroyed.
		undeployStream();
		waitForXD();
		rabbitSource.destroyQueue();
	}
Destroys the queue that was created by this test.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/RabbitTest.java