Connections & Observability

This reference documents the RabbitMQ (AMQP 0-9-1) connector's observability surface: the dashboard HTTP endpoints, the Prometheus metric families, the SSE feed, and the audit events the connector emits. The dashboard APIs are on the internal API port and are network-protected like all /api/* routes.

Dashboard APIs

GET /api/amqp/connections

Node-local live connection list with per-connection metadata: client ID, source IP, channels, consumers, and vhost. Use it to confirm the connector accepted connections after an upgrade — see Configuration.

GET /api/amqp/topology

Cluster-synced view of exchanges, queues, and bindings, with message and consumer counts and inert-argument badges (x-max-length-bytes, x-queue-type, x-queue-mode and x-max-priority are flagged here so operators can see that a queue declared with one of them is not actually enforcing it — enforced arguments such as x-max-length are not badged). See Capabilities.

Prometheus metrics

Gauges

Counters

SSE feed

The connectors SSE event carries an "amqp" group key with per-vhost stats:

{
  "connections": 3,
  "channels": 7,
  "consumers": 5,
  "publishes_total": 1024,
  "delivers_total": 1019,
  "confirms_nacked_total": 0,
  "returns_total": 2,
  "vhosts": { "default": { "publishes_total": 1024, "delivers_total": 1019 } }
}

Audit events

Audit events use Transport amqp and carry SourceIP and ClientID:

Related