0

我正在尝试将队列(Q1)中的所有消息复制到另一台机器上运行的另一个队列(Q2)。

我正在使用铲子插件,两个节点都在运行 amqp 091。我已经测试了连接,如果我将目标队列设置为不存在的队列,它确实会在单独的机器上创建一个新队列,所以我知道连接工作。

rabbitmqctl set_parameter shovel test '{"src-uri": "amqp://guest:guest@localhost:5672", "src-queue": "q1", "ack-mode": "on-confirm", "dest-uri": "amqp://guest:guest@host:5672", "dest-queue": "q2"}'

我希望插件将所有现有消息传输到 Q2,但是它们没有被传输。铲子插件不这样做吗?

4

1 回答 1

0

这是因为消息不在Ready状态中。我不得不杀死我的芹菜工人,然后消息成功传输。

于 2019-08-20T20:00:14.190 回答