1

抱歉,如果这是重复的问题,但即使经过大量搜索,我也很难让它工作。感谢您提前提供任何帮助!

我有两个 RabbitMQ 实例在我的机器上运行的 docker 容器中运行,如下所示。

C:\WINDOWS\system32>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-rabbit-snt”传递到“shovel-rabbit-rcv”代理并在我的接收器代码中获取它。但我无法让铲子进入运行状态并始终从 RabbitMQ 管理 UI 获得以下错误消息。

{{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.
4

0 回答 0