RabbitMQ:双向联合代理,如何使所有队列弹出消息?

问题描述 投票:1回答:2

我有两个配置有联合插件的代理[1]。两者都指向上游。

我的测试是:

  • 在代理A上发布消息
  • 在经纪人B上消费

结果是:

  • 在经纪人B作品上消费
  • <代理B上的队列弹出消息
  • 经纪人A上的队列仍然有消息
    • 我看到的问题是:如果我总是在一个代理上发布,然后又在另一个代理上消耗->,那么发布代理上的队列将一直增长,直到队列满并开始丢弃消息。

我想要的结果是:

  • 当消费者在代理B上消费时,代理A和B上的两个队列都会弹出其消息

当使用者在代理B上消费消息时,如何配置RabbitMQ从所有队列中弹出消息?现在,我正在尝试使用RabbitMQ Federation插件。


[1]这两个代理指向彼此作为上游,并且我将它们配置为same way as described in the "simple example" given by the documentation,除了有两个代理彼此指向上游。 code for the publisher looks like thiscode for the consumer looks like this

我有两个配置有联合插件的代理[1]。两者都指向上游。我的测试是:在经纪人A上发布一条消息在经纪人B上消费。结果是:在...上消费...

python rabbitmq messagebroker rabbitmq-federation
2个回答
1
投票

我创建了这个环境:


0
投票

@ Trevor Boyd Smith,也许您可​​以考虑如下所示的选项2或3。

© www.soinside.com 2019 - 2024. All rights reserved.