0

我正在尝试通过代码和使用 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 -> admin -> Shovel Status

{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 而不是邮递员执行所有这些操作时，我收到了同样的错误。

不知道我哪里出错了。

4

1 回答 1

0

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

于 2020-10-08T06:11:22.213 回答