【问题标题】:Rabbitmq. Move part of messages from one queue to another兔子MQ。将部分消息从一个队列移动到另一个队列
【发布时间】:2022-06-20 13:00:05
【问题描述】:

我有两个队列

例如:

A = ['foo', 'abo', 'aboba', 'bar'];
B = [];

我只想将 'aboba', 'bar' 从队列 A 移动到 B。切开A的哪一边并不重要。

我知道 rabbitmq 铲子,但我没有在这个插件中找到适合我的工具。

【问题讨论】:

  • @Luuk,不幸的是没有。我已经看到了这些问题。我只需要传送几条消息。并非来自队列 A 的所有消息
  • this 可能会解决您的问题,但我无法监督这是否会产生另一个问题(这 = 从队列中读取所有消息,并将它们重新发布到正确的队列)
  • @Luuk,是的。这个解决方案会产生另一个问题。
  • 好吧,那不知道能不能,

标签: rabbitmq rabbitmq-shovel


【解决方案1】:

在您的示例中,您可以将 max-length-policy 设置为 2,然后使用铲子移动剩余的消息。

这不是一个通用的解决方案,因为您可能不知道要在队列中的哪个深度创建剪辑。

【讨论】:

    【解决方案2】:

    此页面详细介绍了将队列拆分为 2 的过程,尽管我没有尝试过:https://doc.oroinc.com/backend/mq/rabbit-mq/divide-single-queue-to-separate-queues/

    【讨论】:

      最近更新 更多