抱歉,如果这是重复的问题,但即使经过大量搜索,我也很难让它工作。感谢您提前提供任何帮助!
我有两个 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.