public void createQueue() {
		RabbitAdmin admin = new RabbitAdmin(connectionFactory);
		Queue sourceQueue = new Queue(queue, false, false, true);
		admin.declareQueue(sourceQueue);
		TopicExchange exchange = new TopicExchange(DEFAULT_EXCHANGE);
		admin.declareExchange(exchange);
		admin.declareBinding(
				BindingBuilder.bind(sourceQueue).to(exchange).with("rabbitfixture.*"));
	}
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