如何使队列在 ActiveMQ 中只允许一个消费者

Question

我希望只有零个或一个消费者连接到一个队列，如果一个新的消费者想连接到这个队列，前一个消费者的连接将被关闭，新的消费者将连接到这个队列。我怎样才能做到这一点 ？提前感谢您的帮助。

Answer 1

我认为 ActiveMQ 不支持开箱即用。您可以编写一个 BrokerPlugin 来跟踪消费者，并在新消费者的 addConsumer 操作中为旧消费者注入 removeConsumer 调用。我不确定这将如何影响第一个消费者。

但是你为什么要这样做呢？只有一个消费者就够了吗？您是否必须让新的消费者请求替换旧的请求？如果没有，您应该使用exclusive consumers。