How to set custom Rabbit (pika) overflow policy?

Question

Python

I set the maximum queue length like this:

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

You need to set your own logic for processing messages that did not fit in the queue. How can I do that?
Rabbit version 3.6.6

Answer 1

In addition to the previous answer, you can also add such a mechanism - Dead Letter Exchanges .