Задать вопрос

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

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

Надо задать свою логику обработки сообщений которые не поместились в очередь. Как это можно сделать?
Rabbit version 3.6.6
  • Вопрос задан
  • 135 просмотров
Подписаться 1 Простой Комментировать
Помогут разобраться в теме Все курсы
  • Нетология
    Python-разработчик: расширенный курс + нейросети
    12 месяцев
    Далее
  • Skillbox
    Python-разработчик
    10 месяцев
    Далее
  • ProductStar
    Профессия: Python-разработчик
    8 месяцев
    Далее
Пригласить эксперта
Ответы на вопрос 1
@yarkin
В дополнение к предыдущему ответу можно ещё добавить вот такой механизм - Dead Letter Exchanges.
Ответ написан
Комментировать
Ваш ответ на вопрос

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

Похожие вопросы