diff --git a/aio_pika/message.py b/aio_pika/message.py index b94333ab..eb06b994 100644 --- a/aio_pika/message.py +++ b/aio_pika/message.py @@ -306,6 +306,15 @@ def process(self, requeue=False, reject_on_redelivered=False, ignore_processed=F ... # the message will be rejected ... print(message.body) + Example with ignore_processed=True + + >>> def on_message_received(message: IncomingMessage): + ... with message.process(ignore_processed=True): + ... # Now (with ignore_processed=True) you may reject (or ack) message manually too + ... if True: # some reasonable condition here + ... message.reject() + ... print(message.body) + :param requeue: Requeue message when exception. :param reject_on_redelivered: When True message will be rejected only when message was redelivered. :param ignore_processed: Do nothing if message already processed