#rabbitmq #rabbitmq-shovel
#rabbitmq — кролик #rabbitmq-shovel #rabbitmq
Вопрос:
Извините, если это повторяющийся вопрос, но мне трудно заставить это работать даже после долгих поисков. Заранее спасибо за любую помощь !!.
У меня есть два экземпляра RabbitMQ, запущенных внутри контейнера docker, работающего на моей машине, как показано ниже.
C:WINDOWSsystem32>docker ps
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
20c1ceda0013 datafyit/rabbitmq:shovel "docker-entrypoint.s…" 4 hours ago Up About an hour 4369/tcp, 5671/tcp, 15671/tcp, 25672/tcp, 0.0.0.0:32791->5672/tcp, 0.0.0.0:32790->15672/tcp shovel-rabbit-snt
d467418754ef datafyit/rabbitmq:shovel "docker-entrypoint.s…" 4 hours ago Up 4 hours 4369/tcp, 5671/tcp, 15671/tcp, 25672/tcp, 0.0.0.0:32783->5672/tcp, 0.0.0.0:32782->15672/tcp shovel-rabbit-rcv
Я пытаюсь настроить плагин shovel, чтобы я мог передавать сообщения от брокера «shovel-rabbit-snt» через плагин shovel брокеру «shovel-rabbit-rcv» и получать их в моем коде получателя.
Но я не могу перевести shovel в рабочее состояние и всегда получаю следующее сообщение об ошибке из пользовательского интерфейса управления RabbitMQ.
{{badmatch,{error,econnrefused}},
[{rabbit_shovel_worker,make_conn_and_chan,2,
[{file,"src/rabbit_shovel_worker.erl"},{line,238}]},
{rabbit_shovel_worker,handle_cast,2,
[{file,"src/rabbit_shovel_worker.erl"},{line,63}]},
{gen_server2,handle_msg,2,[{file,"src/gen_server2.erl"},{line,1032}]},
{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,247}]}]}
Моя Конфигурация Лопаты: —
Source amqp://guest:guest@172.17.0.4:32791/
Sender
queue
Destination amqp://guest:guest@172.17.0.2:32783/
Receiver
queue
Prefetch count ?
Reconnect delay
Add headers ○
Ack mode on-confirm
Auto-delete never.