Как настроить плагин Shovel для двух экземпляров RabbitMQ, работающих на одном компьютере

#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.