How to Implement a Dead Letter Queue Replay in Python

import json
from collections import deque

class DeadLetterQueue:
    def __init__(self):
        self.messages = deque()
    
    def add_message(self, message_id, payload, attempts=3):
        """Add a message to the DLQ with retry metadata."""
        self.messages.append({
            "id": message_id,
            "payload": payload,
            "attempts_left": attempts
        })
    
    def replay(self, message_id):
        """Replay a specific message, decrementing its attempts."""
        for msg in self.messages:
            if msg["id"] == message_id:
                if msg["attempts_left"] <= 0:
                    print(f"Message {message_id} exhausted (0 retries left)")
                    return None
                msg["attempts_left"] -= 1
                payload = msg["payload"]
                print(f"Replayed {message_id}: {json.dumps(payload)}")
                return payload
        print(f"Message {message_id} not found")
        return None

if __name__ == "__main__":
    dlq = DeadLetterQueue()
    dlq.add_message(1, {"event": "payment_failed", "amount": 99.50})
    dlq.add_message(2, {"event": "email_bounced", "address": "user@example.com"})
    
    dlq.replay(1)
    dlq.replay(2)
    dlq.replay(1)
    dlq.replay(1)
    dlq.replay(99)