使用 RabbitListener 注释在 Spring Boot 中创建优先级队列

Question

@RabbitListener(bindings = @QueueBinding(value = @Queue(value = "${queue}",
                durable = "true", autoDelete = "false",
                exchange = @Exchange(value = "${exchange}"),
                key = "${binding}"),concurrency = "${concurrency}")

这会创建一个队列，我该如何创建优先级队列？

Answer 1

所以我发现应该删除现有的队列和交换器。下面的代码创建了一个优先级队列。我在网上找过这个，但找不到任何答案。所以，我在这里发布这个。

@RabbitListener(bindings = @QueueBinding(value = @Queue(value = "${queue}",
                durable = "true", autoDelete = "false",
                arguments = {@Argument(name = "x-max-priority", value = "10",
                type = "java.lang.Integer")}),
                exchange = @Exchange(value = "${exchange}"),
                key = "${binding}"),concurrency = "${concurrency}")