Плагин Shovel не передает существующие сообщения в очередь назначения

Я пытаюсь скопировать все сообщения в очереди (Q1) в другую очередь (Q2), работающую на другом компьютере.

Я использую плагин shovel, и на обоих узлах работает 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, однако они не передаются. Плагин лопаты этого не делает?


person Michael Laythe    schedule 20.08.2019    source источник


Ответы (1)


Это потому, что сообщения не были в состоянии Ready. Мне пришлось убить своего работника сельдерея, после чего сообщения были успешно переданы.

person Michael Laythe    schedule 20.08.2019