Management UI

http://<IP_OF_THE_VM>:31672/

‍

‍

ℹ️ The Management UI allows you to create exchanges, queues, bindings and monitor messages in real time without the need for code.

‍

AMQP — Connection string

amqp://<USER>:<PASSWORD>@<IP_OF_THE_VM>:30672/

# View the RabbitMQ pod
`kubectl get pods -A | grep rabbitmq`

# View the installation log
`tail -f /var/log/cuemby/bootstrap.log`

# Verify that the ports are listening
`ss -tlnp | grep -E '30672|31672'`

‍

Expected output

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

Examples of connection by language

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

)
) channel = connection.channel()

# Declare a queue and publish a message
channel.queue_declare(queue="my-queue", durable=True)
channel.basic_publish(exchange="", routing_key="my-queue", body="Hello from Cuemby")

// Node.js (amqplib)
const conn = await amqp.connect("amqp://<USER>:<PASSWORD>@<VM_IP>:30672");
const ch = await conn.createChannel();
await ch.assertQueue("my-queue", { durable: true });
ch.sendToQueue("my-queue", Buffer.from("Hello from Cuemby"));

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

‍

Verify from the Management UI

1. Open http://<VM_IP>:31672/ and log in.
2. Go to Queues to view queued messages and consumption rate.
3. Go to Connections to view active producers and consumers.
4. Use Publish message in a queue to send test messages from the UI.

💡 Tip: Use `durable: true` when declaring queues in production so that messages survive broker restarts. Without this option, messages are lost if the pod restarts.