Rabbitmq Cloud

RabbitMQ is the most widely deployed open-source message broker — preferred for task queues and work distribution where message acknowledgment, dead-letter queues, and complex routing patterns (fanout, topic, direct) are required. For agents: publish messages to exchanges (routed to queues by binding rules), consume messages with acknowledgment for reliable processing, and use the Management API for queue inspection and administrative tasks. Self-hostable as a single Docker container; CloudAMQP provides managed hosting. Confidence is docs-derived.

AMQP client (pika, Python). connection = pika.BlockingConnection(pika.ConnectionParameters("localhost", credentials=pika.PlainCredentials(user, pass))). channel = connection.channel(). channel.queue_declare(queue="tasks", durable=True). channel.basic_publish(exchange="", routing_key="tasks", body=json.dumps(task), properties=pika.BasicProperties(delivery_mode=2)). Consuming: channel.basic_consume(queue="tasks", on_message_callback=callback, auto_ack=False). callback: channel.basic_ack(delivery_tag). Management HTTP API at {host}:15672/api. GET /api/queues/{vhost} lists queues. GET /api/queues/{vhost}/{queue} retrieves queue metrics (message count, consumers). PUT /api/queues/{vhost}/{queue} creates queue. DELETE /api/queues/{vhost}/{queue} purges queue. GET /api/overview cluster health.

AMQP auth: pika.PlainCredentials(username, password). Default credentials: guest/guest (localhost only — change for production). Management HTTP API: Authorization: Basic base64(user:password). TLS: pika.SSLOptions for encrypted connections. Virtual hosts: isolate environments (/production, /staging). HTTPS: configure management API TLS. User management: via Management API or rabbitmqctl CLI (create users, set permissions per vhost).

Acknowledgment: explicit ack/nack required for reliable processing (basic_ack / basic_nack). Dead-letter exchange (DLX): configure for failed message routing. Queue durability: durable=True + persistent delivery_mode=2 for crash-safe messages. Prefetch: channel.basic_qos(prefetch_count=1) for fair work distribution. RabbitMQ uptime: self-hosted (operator-managed); CloudAMQP at status.cloudamqp.com. Message TTL: configure per-queue or per-message. Consumer cancellation: connection drop automatically requeues unacked messages. Management API rate: suitable for monitoring, not high-frequency polling.

rabbitmq.com/docs covers AMQP concepts (exchanges, queues, bindings), pika tutorial series, Management API reference, and clustering guide. Getting started: docker run rabbitmq:3-management — running in 30 seconds; management UI at localhost:15672. pika: pip install pika. CloudAMQP free tier: 1M messages/month. Community via RabbitMQ mailing lists and Stack Overflow (rabbitmq tag). Excellent tutorial series (6 official RabbitMQ tutorials in Python, Java, Go, etc.).