如何使用可变数量的吊舱实现至少一次的安慰消息传递？

Question

我们有一个库伯奈特部署有2个吊舱。我们希望以1:n的方式向这两个吊舱发送消息(每条消息都应该被双方接收)，并且每条消息至少应该发送一次(QoS1)。

为了实现同样的目标，我们有一个主题和预先创建的4个队列。所有四个队列都订阅了主题，因此接收来自同一主题的消息。现在，我们希望启动这4个吊舱，并确保每个吊舱都从4个不同的队列中消耗。但是，豆荚没有任何索引，因此很难决定必须从哪个队列订阅。是否有一种方法可以在加入前检查队列是否有活动的使用者，以确保它没有加入已经消耗的队列？

Answer 1

我不确定我是否确切地理解了您的问题，但是如果您想知道流是否能够接收来自队列的消息，也许这个主动消费者指示可以帮助您。