message-queues

What I do

• Implement reliable message publishing and consuming
• Handle message ordering and deduplication
• Use dead letter queues for failed messages
• Implement retry with exponential backoff
• Use topic exchanges for pub/sub patterns
• Handle consumer groups and load balancing
• Design for at-least-once or exactly-once semantics
• Monitor queue health and lag

When to use me

When implementing message queue systems (RabbitMQ, Kafka, SQS).

RabbitMQ Patterns

import pika
import json
from typing import Callable
from dataclasses import dataclass
from datetime import datetime