动态铲子在 Rabbitmq 中失败

Question

我正在尝试通过代码和使用 UI 在我的 RabbitMQ 实例中创建动态铲子。在这两种情况下，我都可以制作铲子。但是，它后来失败了，无法按需要移动消息。

通过邮递员

PUT -- http://rabbitinstance011:15672/api/parameters/shovel/dev_test/test01

{"value": {"src-protocol": "amqp091", "src-uri": "amqp://naxi@example.com@/dev_test",
 "src-queue": "dlq1", "dest-protocol": "amqp091", 
 "dest-uri": "amqp://naxi@example.com@/dev_test",
  "dest-queue": "q1", "src-delete-after": "queue-length"}}

响应：201

在UI -> 管理员 -> 铲状态

{failed_to_connect_using_provided_uris,
    [{rabbit_amqp091_shovel,make_conn_and_chan,2,
         [{file,"src/rabbit_amqp091_shovel.erl"},{line,324}]},
     {rabbit_amqp091_shovel,connect_source,1,
         [{file,"src/rabbit_amqp091_shovel.erl"},{line,78}]},
     {rabbit_shovel_worker,handle_cast,2,
         [{file,"src/rabbit_shovel_worker.erl"},{line,64}]},
     {gen_server2,handle_msg,2,[{file,"src/gen_server2.erl"},{line,1050}]},
     {proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,247}]}]}

当我尝试使用代码以及 UI 而不是邮递员来完成所有这些操作时，我收到了同样的错误。

不确定我哪里错了。

Answer 1

很简单。必须在用户名中创建一个没有“@”的新用户。

动态铲子在 Rabbitmq 中失败

dynamic shovels fail in Rabbitmq

rabbitmq

rabbitmq-shovel