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

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

Надо задать свою логику обработки сообщений которые не поместились в очередь. Как это можно сделать?
Rabbit version 3.6.6
  • Вопрос задан
  • 58 просмотров
Пригласить эксперта
Ответы на вопрос 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.
Ответ написан
Ваш ответ на вопрос

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

Войти через TM ID
Похожие вопросы