我在机器 A 上有以下 RabbitMQ 配置:
[
{rabbit,
[
{default_user, <<"user">>},
{default_pass, <<"pass">>}
]
},
{rabbitmq_shovel,
[{shovels, [{shovel_test,
[{sources, [{brokers, ["amqp://"]}]},
{destinations, [{broker, "amqp://user:password@ip_of_machine_B:5672"}]},
{queue, <<"queue_test">>},
{prefetch_count, 1},
{ack_mode, on_confirm},
{publish_properties, [ {delivery_mode, 2} ]},
{reconnect_delay, 5}
]}
]}
]}
].
机器 A 上带有 Shovel 插件的 RabbitMQ 位于 docker 网络中,机器 B 上的 RabbitMQ 位于另一个 docker 网络中。在机器 B 上,端口 5672 已打开。将一些消息发送到第一个 RabbitMQ 后,它不会将其发送到第二个。
有任何想法吗?是兔子的问题还是机器的问题?