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

Question

[Александр Кулага]

Установил максимальную дину очереди таким образом:

pika_channel.queue_declare(
                self.RABBIT_QUEUE_NAME,
                durable=False,
                arguments={"x-max-length": 500000},
            )

Надо задать свою логику обработки сообщений которые не поместились в очередь. Как это можно сделать?
Rabbit version 3.6.6

Answer 1

[Сергей]

В дополнение к предыдущему ответу можно ещё добавить вот такой механизм - Dead Letter Exchanges.