1

我在机器 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 后,它不会将其发送到第二个。

有任何想法吗?是兔子的问题还是机器的问题?

4

0 回答 0