我正在尝试将队列 (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"}'
我希望插件将所有现有消息传输到第 2 季度，但它们没有被传输。铲子插件不这样做吗？
这是因为消息未处于Ready状态。我不得不杀死我的芹菜工人，然后消息成功传输。