# Connections & Observability (/connectors/rabbitmq/reference/connections-endpoint)



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 [#dashboard-apis]

### `GET /api/amqp/connections` [#get-apiamqpconnections]

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](/connectors/rabbitmq/concepts/configuration).

### `GET /api/amqp/topology` [#get-apiamqptopology]

Cluster-synced view of exchanges, queues, and bindings, with message and consumer counts and
**inert-argument badges** (the arguments listed under gotcha #7 are flagged here so operators
can see that a queue declared with, e.g., `x-max-length` is not actually enforcing it). See
[Capabilities](/connectors/rabbitmq/reference/capabilities).

## Prometheus metrics [#prometheus-metrics]

### Gauges [#gauges]

| Metric                    | Meaning               |
| ------------------------- | --------------------- |
| `kubemq_amqp_connections` | Live AMQP connections |
| `kubemq_amqp_channels`    | Live AMQP channels    |
| `kubemq_amqp_consumers`   | Live AMQP consumers   |

### Counters [#counters]

| Metric                               | Meaning                                             |
| ------------------------------------ | --------------------------------------------------- |
| `kubemq_amqp_publishes_total{vhost}` | Publishes, by vhost                                 |
| `kubemq_amqp_delivers_total{vhost}`  | Deliveries, by vhost                                |
| `kubemq_amqp_confirms_nacked_total`  | Publisher-confirm nacks (gotcha #3)                 |
| `kubemq_amqp_returns_total`          | `basic.return` events (mandatory unroutable, `312`) |

## SSE feed [#sse-feed]

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

```json
{
  "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]

Audit events use Transport `amqp` and carry `SourceIP` and `ClientID`:

| Event                                                         | When                                                      |
| ------------------------------------------------------------- | --------------------------------------------------------- |
| `client.connected` / `client.disconnected` / `client.timeout` | Connection lifecycle                                      |
| `auth.success` / `auth.failure`                               | SASL PLAIN authentication outcome                         |
| `amqp.exchange.declared` / `amqp.exchange.deleted`            | Exchange lifecycle                                        |
| `amqp.queue.declared` / `amqp.queue.deleted`                  | Queue lifecycle                                           |
| `amqp.binding.created` / `amqp.binding.deleted`               | Binding lifecycle                                         |
| `subscription.created` / `subscription.deleted`               | Consumer lifecycle                                        |
| `amqp.publish.denied`                                         | Write denial on a routed queue (publish silently dropped) |
| `amqp.dlx.routed`                                             | A message was dead-lettered                               |

## Related [#related]

<Cards>
  <Card title="Capabilities" href="/connectors/rabbitmq/reference/capabilities" description="The forced caps and inert-argument badges that this endpoint surfaces." />

  <Card title="Error & Reason Codes" href="/connectors/rabbitmq/reference/error-codes" description="The 311–541 close codes behind confirms_nacked_total and returns_total." />

  <Card title="Authentication" href="/connectors/rabbitmq/how-to/authentication" description="The SASL PLAIN outcomes behind auth.success / auth.failure and amqp.publish.denied." />

  <Card title="Reliability" href="/connectors/rabbitmq/how-to/reliability" description="Publisher confirms, returns, and dead-lettering as observed through these metrics." />
</Cards>
