rabbitmq之自动配置交换机与队列

@Autowired
RabbitTemplate rabbitTemplate;

@PostConstruct
public void initExchangeQueue() {
    rabbitTemplate.execute(channel -> {
        List<ExchangeQueue> exchangeQueues = Constant.exchangeQueues;
        for (ExchangeQueue exchangeQueue : exchangeQueues) {
            Exchange exchange = exchangeQueue.getExchange();
            channel.exchangeDeclare(exchange.getName(), exchange.getType(), exchange.isDurable(), exchange.isAutoDelete(), exchange.getArguments());
            Queue queue = exchangeQueue.getQueue();
            channel.queueDeclare(queue.getName(), queue.isDurable(), queue.isExclusive(), queue.isAutoDelete(), null);
            String routingKey = exchangeQueue.getRoutingKey();
            if (routingKey != null) {
                channel.queueBind(queue.getName(), exchange.getName(), routingKey);
            }
        }
        return null;
    });
}

String exchange, String type, boolean durable, boolean autoDelete,Map<String, Object> arguments

String queue, boolean durable, boolean exclusive, boolean autoDelete,Map<String, Object> arguments