python - How do I determine how many times a message has been rejected/re-queued in RabbitMQ? -
i'm using rabbitmq pika (python), , i'm wondering if there's way determine how many times message has been re-queued?
the general idea i'd worker able tell message it's dealing has been rejected/re-queued x times before, , take appropriate action error processing , explicitly remove item queue if reaches limit of y retries.
i know potentially make copy of the message, increment value of priority property (or increment value in headers), publish copy queue , ack original message (similar approach of this example found), prefer explicitly nack , re-queue message.
any ideas?
Comments
Post a Comment