@Override
	public void cleanup() {
		if (!queues.isEmpty()) {
			for (String queue : queues) {
				rabbitAdmin.deleteQueue("xdbus." + queue);
				// delete any partitioned queues
				for (int i = 0; i < 10; i++) {
					rabbitAdmin.deleteQueue("xdbus." + queue + "-" + i);
				}
				rabbitAdmin.deleteQueue("foo." + queue);
				// delete any partitioned queues
				for (int i = 0; i < 10; i++) {
					rabbitAdmin.deleteQueue("foo." + queue + "-" + i);
				}
			}
		}
		if (!topics.isEmpty()) {
			for (String exchange : topics) {
				rabbitAdmin.deleteExchange("xdbus." + exchange);
			}
		}
	}
Test support class for {@link RabbitMessageBus}.

@author Ilayaperumal Gopinathan
@author Gary Russell
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/bus/rabbit/RabbitTestMessageBus.java