Monitor message queues, job processing, and detect backpressure
Monitors message queue depth, processing time, and consumer lag to detect backpressure and bottlenecks. Instrumented spans trigger when publishing or consuming messages from Kafka, RabbitMQ, or other queue systems.
/plugin marketplace add nexus-labs-automation/backend-observability/plugin install nexus-labs-automation-backend-observability@nexus-labs-automation/backend-observabilityThis skill inherits all available tools. When active, it can use any tool Claude has access to.
Queues decouple systems but hide problems. Track depth, processing time, and lag.
| Metric | Type | Description |
|---|---|---|
queue.messages.published | Counter | Messages sent |
queue.messages.consumed | Counter | Messages processed |
queue.process.duration | Histogram | Processing time |
queue.process.errors | Counter | Processing failures |
queue.depth | Gauge | Pending messages |
queue.consumer.lag | Gauge | Behind by N messages |
| Attribute | Example | Required |
|---|---|---|
messaging.system | kafka, rabbitmq | Yes |
messaging.destination | orders, notifications | Yes |
messaging.operation | publish, process | Yes |
job.type | send_email | Recommended |
Before: Start span (kind=PRODUCER), inject trace context into headers, start timer
After: Record duration, increment published, record errors, end span
On receive: Extract trace context, start span (kind=CONSUMER), start timer
After: Record duration, increment consumed, record errors, end span
| Issue | Detection | Cause |
|---|---|---|
| Growing depth | queue.depth increasing | Consumer too slow |
| Consumer lag | lag > 0 and increasing | Crashed consumer, slow processing |
| High error rate | errors/consumed > 5% | Bad messages, downstream issues |
references/platforms/{platform}/worker.mdreferences/patterns/retry-backoff.mdUse when working with Payload CMS projects (payload.config.ts, collections, fields, hooks, access control, Payload API). Use when debugging validation errors, security issues, relationship queries, transactions, or hook behavior.
Applies Anthropic's official brand colors and typography to any sort of artifact that may benefit from having Anthropic's look-and-feel. Use it when brand colors or style guidelines, visual formatting, or company design standards apply.
Creating algorithmic art using p5.js with seeded randomness and interactive parameter exploration. Use this when users request creating art using code, generative art, algorithmic art, flow fields, or particle systems. Create original algorithmic art rather than copying existing artists' work to avoid copyright violations.