Management UI

http://<IP_DE_LA_VM>:31672/

‍

‍

ℹ️ La Management UI permite crear exchanges, queues, bindings y monitorear mensajes en tiempo real sin necesidad de código.

‍

AMQP — Connection string

amqp://<USUARIO>:<PASSWORD>@<IP_DE_LA_VM>:30672/

# Ver el pod de RabbitMQ
kubectl get pods -A | grep rabbitmq

# Ver log de instalación
tail -f /var/log/cuemby/bootstrap.log

# Verificar que los puertos están escuchando
ss -tlnp | grep -E '30672|31672'

‍

Respuesta esperada

NAME                        READY   STATUS    RESTARTS
rabbitmq-xxxxxxxxx-xxxxx    1/1     Running   0        ← Running ✓

Ejemplos de conexión por lenguaje

# Python (pika)
import pika
connection = pika.BlockingConnection(
    pika.ConnectionParameters(
        host="<IP_DE_LA_VM>", port=30672,
        credentials=pika.PlainCredentials("<USUARIO>", "<PASSWORD>")
    )
)
channel = connection.channel()

# Declarar una queue y publicar un mensaje
channel.queue_declare(queue="mi-queue", durable=True)
channel.basic_publish(exchange="", routing_key="mi-queue", body="Hola desde Cuemby")

// Node.js (amqplib)
const conn = await amqp.connect("amqp://<USUARIO>:<PASSWORD>@<IP_DE_LA_VM>:30672");
const ch = await conn.createChannel();
await ch.assertQueue("mi-queue", { durable: true });
ch.sendToQueue("mi-queue", Buffer.from("Hola desde Cuemby"));

// Java (spring-amqp)
spring.rabbitmq.host=<IP_DE_LA_VM>
spring.rabbitmq.port=30672
spring.rabbitmq.username=<USUARIO>
spring.rabbitmq.password=<PASSWORD>

‍

Verificar desde la Management UI

1. Abre http://<IP_DE_LA_VM>:31672/ e inicia sesión.
2. Ve a Queues para ver mensajes en cola y tasa de consumo.
3. Ve a Connections para ver producers y consumers activos.
4. Usa Publish message en una queue para enviar mensajes de prueba desde la UI.

💡 Tip: Usa durable: true al declarar queues en producción para que los mensajes sobrevivan reinicios del broker. Sin esta opción, los mensajes se pierden si el pod se reinicia.