Message Queues
Give Claude visibility into your queues. AI monitors throughput, identifies bottlenecks, and keeps messages flowing.
Before
You
Email sending is delayed. Is there a backup in the email queue?
I can't see your message queues—no visibility into Redis, RabbitMQ, or SQS.
You'll need to check your queue dashboard or run CLI commands.
After
You
Email sending is delayed. Is there a backup in the email queue?
Using pipe.queue_stats
pipe.queue_stats(queue: "email")
Queue Status: email
Depth: 4,832 messages (backed up)
Process rate: 50/min (normal: 500/min)
Oldest message: 2h 15m ago
Worker status: 1 of 5 healthy
Bottleneck found: 4 email workers crashed. Processing at 10% capacity. Restarting workers now...
Available via MCP (Model Context Protocol)
pipe.queue_stats(queue)
"How backed up is email?"
pipe.enqueue(queue, message)
"Add this to the queue"
pipe.dead_letter_count()
"How many failed messages?"
pipe.purge_queue(queue)
"Clear the stuck queue"
We're building Pipe as part of Phase 2. Follow along to get early access.