我正在尝试将队列(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,但是它们没有被传输。铲子插件不这样做吗?