private List<String> findJobQueues(String adminUri, String vhost, String busPrefix, String job,
			RestTemplate restTemplate) {
		List<String> removedQueues = new ArrayList<>();
		String jobQueueName = MessageBusSupport.applyPrefix(busPrefix,
				AbstractJobPlugin.getJobChannelName(job));
		String jobRequestsQueuePrefix = adjustPrefix(MessageBusSupport.applyPrefix(busPrefix,
				AbstractJobPlugin.getJobChannelName(job)));
		List<Map<String, Object>> queues = listAllQueues(adminUri, vhost, restTemplate);
		for (Map<String, Object> queue : queues) {
			String queueName = (String) queue.get("name");
			if (job.endsWith("*")) {
				if (queueName.startsWith(jobQueueName.substring(0, jobQueueName.length() - 1))) {
					checkNoConsumers(queueName, queue);
					removedQueues.add(queueName);
				}
			}
			else {
				if (queueName.equals(jobQueueName)) {
					checkNoConsumers(queueName, queue);
					removedQueues.add(queueName);
				}
				else if (queueName.startsWith(jobRequestsQueuePrefix)
						&& queueName.endsWith(MessageBusSupport.applyRequests(""))) {
					checkNoConsumers(queueName, queue);
					removedQueues.add(queueName);
				}
			}
		}
		return removedQueues;
	}
Implementation of {@link BusCleaner} for the {@code RabbitMessageBus}.

@author Gary Russell
@since 1.2
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/integration/bus/rabbit/RabbitBusCleaner.java