Блог

Я пытаюсь создать динамические лопатки в моем экземпляре RabbitMQ как с помощью кода, так и с помощью пользовательского интерфейса. В обоих случаях я могу создать лопату. Однако позже он выходит из строя и не может перемещать сообщения по желанию.

Через Postman

 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

В пользовательском интерфейсе -> администратор -> Состояние лопаты

 {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}]}]}
  

Я получаю те же ошибки, когда пытаюсь сделать все это с помощью кода, а также из пользовательского интерфейса вместо postman.

Не уверен, где я ошибаюсь.

Это было очень просто. Пришлось создать нового пользователя без «@» в имени пользователя.