Блог

Мы пытаемся реализовать сценарий запроса / ответа, в котором сообщения будут удалены сервер (потребитель) не работает. Мы начинаем с отсутствия обменов / очередей в установке rabbit mq.

Существует сервер, который создает свой собственный обмен / очередь, и мы хотим, чтобы это было auto-delete=true .

В случае, если сервер запускается раньше клиента, обмен создается с правильной конфигурацией. Но когда клиент запущен, мы получаем эту ошибку:

RabbitMQ.Client.Исключения.OperationInterruptedException: операция AMQP была прервана: причина закрытия AMQP, инициированная одноранговым узлом, code = 406, text =»PRECONDITION_FAILED — неэквивалентный аргумент ‘auto_delete’ для обмена ‘simple_request’ в vhost ‘****’: получено ‘false’, но текущее значение ‘true'», classId = 40, methodId=10, причина =

В случае, если клиент запускается первым и пытается отправить сообщение, создается обмен с именем очереди, которое мы определили, но это не auto-delete=true то, что приводит к ошибке:

Сбой передачи RabbitMQ: операция AMQP была прервана: причина закрытия AMQP, инициированная одноранговым узлом, code = 406, text =»PRECONDITION_FAILED — неэквивалентный аргумент ‘auto_delete’ для обмена ‘simple_request’ в vhost ‘****’: получено ‘true’, но текущее значение ‘false'»,classId = 40, methodId = 10, причина = сбой передачи RabbitMQ: супервизор останавливается, дополнительные области не могут быть созданы

когда сервер в конечном итоге запускается.

Как мы реализуем очереди автоматического удаления в сценарии ответа на запрос?

Вы можете обновить URI в своем клиенте для очереди обслуживания, чтобы включить параметры строки запроса, чтобы очередь была создана правильно.

rabbitmq://host/vhost/queue?autodelete=trueamp;durable=false

Примечание, которое я включил durable=false , но это только в том случае, если вы используете недолговечную очередь, и я хотел быть полным.