rabbitmq-operationslisted
Install: claude install-skill othmane55/claude-collective-intelligence
# RabbitMQ Operations
Comprehensive skill for managing RabbitMQ in multi-agent orchestration systems.
## Quick Start
### Basic Connection
```javascript
import { RabbitMQClient } from './scripts/rabbitmq-client.js';
const client = new RabbitMQClient({
url: 'amqp://localhost:5672'
});
await client.connect();
```
### Send Message to Queue
```javascript
await client.publishTask({
title: "Process data",
description: "Transform CSV to JSON",
priority: "high"
});
```
### Consume Messages
```javascript
await client.consumeTasks('agent.tasks', async (msg, { ack, nack }) => {
console.log('Received:', msg.task);
// Process task
const result = await processTask(msg.task);
// Acknowledge
ack();
});
```
## Core Concepts
### Queues
Point-to-point messaging with load balancing:
```javascript
// Setup durable queue
await client.setupTaskQueue('agent.tasks');
// Multiple consumers share work
// Each message delivered to ONE consumer
```
### Exchanges
Publish-subscribe with routing:
```javascript
// Fanout - broadcast to all
await client.setupBrainstormExchange('agent.brainstorm');
// Topic - selective routing
await client.setupStatusExchange('agent.status');
```
### Message Patterns
**Work Queue** (Load Balancing):
```
Producer → Queue → Consumer 1
→ Consumer 2
→ Consumer 3
Each message to ONE consumer
```
**Pub/Sub** (Broadcasting):
```
Publisher → Exchange → Queue 1 → Consumer 1
→ Queue 2 → Consumer 2