Monitoring and Observability

curl -u guest:guest http://localhost:15672/api/queues/%2f/my-queue

const axios = require('axios');

const getNodesStats = async () => {
  const response = await axios.get('http://localhost:15672/api/nodes', {
    auth: {
      username: 'guest',
      password: 'guest'
    }
  });
  
  return response.data.map(node => ({
    name: node.name,
    status: node.status,
    memory: node.mem_used / (1024 * 1024) + ' MB'
  }));
};

curl -u guest:guest http://localhost:15672/api/queues/%2f/my-queue

{
  "messages": 100,
  "messages_ready": 50,
  "messages_unacknowledged": 50,
  "message_bytes": 102400,
  "message_bytes_ready": 51200,
  "message_bytes_unacknowledged": 51200,
  "consumers": 2,
  "ack_rate": 10.5,
  "deliver_rate": 15.2,
  "publish_rate": 20.0
}

curl -u guest:guest http://localhost:15672/api/connections

const axios = require('axios');

async function fetchConnectionMetrics() {
  const response = await axios.get('http://localhost:15672/api/connections', {
    auth: { username: 'guest', password: 'guest' }
  });

  const connections = response.data;
  console.log(`Active connections: ${connections.length}`);
  console.log('Connection details:', connections.map(conn => ({
    name: conn.name,
    user: conn.user,
    state: conn.state
  })));
}

fetchConnectionMetrics();

curl -u guest:guest http://localhost:15672/api/nodes/rabbit@localhost

prometheus:
  scrape_configs:
    - job_name: rabbitmq
      static_configs:
        - targets: ['localhost:15692']

const amqp = require('amqplib');

async function publishAndMonitor() {
  const connection = await amqp.connect('amqp://localhost');
  const channel = await connection.createChannel();

  // Publish a message
  const msg = 'Hello, RabbitMQ!';
  channel.publish('', 'my-queue', Buffer.from(msg));

  // Monitor metrics using RabbitMQ Management API
  const metrics = await fetch('http://localhost:15672/api/channels');
  console.log(await metrics.json());

  await channel.close();
  await connection.close();
}

publishAndMonitor();

# Enable Prometheus plugin
rabbitmq-plugins enable rabbitmq_prometheus

# Restart RabbitMQ service
systemctl restart rabbitmq-server

scrape_configs:
  - job_name: 'rabbitmq'
    static_configs:
      - targets: ['localhost:15691']

curl -u guest:guest -X POST "http://localhost:15672/api/alarms" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "queue.length",
    "description": "Queue length exceeds 1000 messages",
    "severity": "warning",
    "condition": {
      "type": "queue.length",
      "threshold": 1000
    }
  }'

curl -X GET http://localhost:15672/api/healthchecks/node/rabbit@localhost

livenessProbe:
  httpGet:
    path: /api/healthchecks/node/rabbit@localhost
    port: 15672
  initialDelaySeconds: 30
  periodSeconds: 10

echo 'log.console = true' >> /etc/rabbitmq/rabbitmq.conf

echo 'log.file = /var/log/rabbitmq/rabbit.log' >> /etc/rabbitmq/rabbitmq.conf

# otel-config.yaml
receivers:
  jaeger:
    protocols:
      thrift_http:
        endpoint: "0.0.0.0:14268"
  otlp:
    protocols:
      http:
        endpoint: "0.0.0.0:4318"

processors:
  batch:
    timeout: 1s

exporters:
  jaeger:
    endpoint: "http://jaeger-collector:14250"
    tls:
      insecure: true

service:
  pipelines:
    traces:
      receivers: [jaeger, otlp]
      processors: [batch]
      exporters: [jaeger]

{
  "dashboard": {
    "title": "RabbitMQ Overview",
    "panels": [
      {
        "title": "Queue Length",
        "type": "graph",
        "targets": [
          {
            "expr": "rabbitmq_queue_messages{queue='my-queue'}"
          }
        ]
      }
    ]
  }
}

# rabbitmq.conf
management.enabled = true
management.listener.port = 15672
management.listener.ip = 0.0.0.0

# Enable alerting
rabbitmq_management.alerts.enabled = true
rabbitmq_management.alerts.thresholds.memory.usage = 80
rabbitmq_management.alerts.thresholds.disk.usage = 90

curl -u guest:guest -X PUT http://localhost:15672/api/parameters/rabbitmq_management/alerts/thresholds/memory/usage \
  -H "Content-Type: application/json" \
  -d '{"value": 85}'