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

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

Надо задать свою логику обработки сообщений которые не поместились в очередь. Как это можно сделать?
Rabbit version 3.6.6
  • Вопрос задан
  • 77 просмотров
Пригласить эксперта
Ответы на вопрос 2
@tumbler
бекенд-разработчик на python
https://www.rabbitmq.com/maxlength.html#max-length...
Overflow behaviour can be set by supplying the x-overflow queue declaration argument with a string value. Possible values are drop-head (default) or reject-publish
Ответ написан
@yarkin
В дополнение к предыдущему ответу можно ещё добавить вот такой механизм - Dead Letter Exchanges.
Ответ написан
Ваш ответ на вопрос

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

Войти через центр авторизации
Похожие вопросы
Humanteq Москва
от 80 000 руб.
Humanteq Москва
от 120 000 руб.
YLab Тольятти
от 90 000 до 150 000 руб.
16 июл. 2019, в 03:05
15000 руб./за проект
16 июл. 2019, в 02:57
5000 руб./за проект
16 июл. 2019, в 00:49
15000 руб./за проект