rabbitmq_broker

RabbitMQ es un message broker AMQP con soporte nativo de prioridades, dead-letter queues y routing avanzado. Alternativa a Redis broker cuando se necesitan garantías de entrega más estrictas.

When to use

Usar como alternativa al Redis broker en el worker_pool_agent si se necesitan prioridades nativas de mensaje, dead-letter queues o routing basado en topic exchange.

Instructions

1. Desplegar: docker run -d rabbitmq:3-management.
2. Configurar en Celery: broker_url = 'amqp://user:pass@rabbitmq:5672//'.
3. Configurar exchanges y queues con prioridad:

   task_queues = [
       Queue('realtime', Exchange('realtime'), routing_key='realtime', queue_arguments={'x-max-priority': 10}),
   ]
   

4. Configurar DLQ: queue_arguments={'x-dead-letter-exchange': 'dlx'}.