public void destroyQueue() {
		RabbitAdmin admin = new RabbitAdmin(connectionFactory);
		admin.deleteQueue(queue);
	}
Creates an instance of the queue on the rabbit broker. If already present then no action is taken.
spring-xd-test-fixtures/src/main/java/org/springframework/xd/test/fixtures/RabbitSource.java