Как задать кастомную политику переполнения Rabbit (pika)?

Установил максимальную дину очереди таким образом:
pika_channel.queue_declare(
                self.RABBIT_QUEUE_NAME,
                durable=False,
                arguments={"x-max-length": 500000},
            )

Надо задать свою логику обработки сообщений которые не поместились в очередь. Как это можно сделать?
Rabbit version 3.6.6
  • Вопрос задан
  • 133 просмотра
Пригласить эксперта
Ответы на вопрос 1
@yarkin
В дополнение к предыдущему ответу можно ещё добавить вот такой механизм - Dead Letter Exchanges.
Ответ написан
Комментировать
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы
28 мар. 2024, в 21:25
2000 руб./за проект
28 мар. 2024, в 21:17
5000 руб./за проект
28 мар. 2024, в 20:46
150000 руб./за проект