queue-pilot

library0.5.3jsnpmunverified

MCP server for inspecting RabbitMQ and Kafka message queues, with JSON Schema validation for message payloads. Version 0.5.3. Active development with regular updates. Differentiates from generic MCP tools by combining multi-broker support (RabbitMQ management plugin, Kafka via peer dep @confluentinc/kafka-javascript) with schema validation on both inbound (publishing) and outbound (inspection) messages. Requires Node.js >=22 and a running broker. Provides an MCP server that works with any MCP client (Claude, Cursor, VS Code, etc.).

devops

npm install queue-pilot

github ↗package ↗homepage ↗

INSTALL

IMPORT

SIG · QUEUE-PILOT

queue-pilot

devopsjavascriptv0.5.3

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

queue-pilot (MCP server)

✓ npx queue-pilot --schemas /path/to/schemas

✗ npx queue-pilot without schema path (will fail with missing schema directory)

Package is a CLI MCP server, not a library. Must be run via npx or direct command. Schema path is required.

init command

✓ npx queue-pilot init --schemas ./schemas --client claude-code

✗ queue-pilot init --schemas ./schemas (without npx prefix; works only if globally installed)

The init command generates MCP client config. Use --help to see all options.

Environment variables for credentials

✓ RABBITMQ_USER=admin RABBITMQ_PASS=secret npx queue-pilot --schemas ./schemas

✗ npx queue-pilot --schemas ./schemas --rabbitmq-user admin (init command only; runtime uses env vars)

Credentials are set as environment variables (RABBITMQ_USER, RABBITMQ_PASS, etc.) to avoid exposing in process list.

Creates a sample JSON Schema file and generates MCP client configuration for Claude Code.

mkdir -p schemas cat > schemas/order.created.json << 'EOF' { "$id": "order.created", "$schema": "http://json-schema.org/draft-07/schema#", "title": "Order Created", "type": "object", "required": ["orderId", "amount"], "properties": { "orderId": { "type": "string" }, "amount": { "type": "number" } } } EOF echo "Schema created. Now init for Claude Code:" npx queue-pilot init --schemas $(pwd)/schemas --client claude-code

Debug

Known issues

breakingNode.js <22.0.0 is not supported. The server will fail to start.

fix

Upgrade Node.js to version >=22.0.0.

affects: >=0.1.0

breakingKafka support requires the @confluentinc/kafka-javascript peer dependency to be installed. Missing it causes a runtime error.

fix

Install @confluentinc/kafka-javascript: npm install @confluentinc/kafka-javascript

affects: >=0.1.0

gotchaThe --schemas argument must be an absolute path. Relative paths may cause 'directory not found' errors.

fix

Use $(pwd)/schemas or an absolute path like /home/user/schemas.

affects: >=0.5.0

gotchaThe init command generates a config snippet that references environment variables. If those variable are not set at runtime, the server fails with connection errors.

fix

Set environment variables (RABBITMQ_USER, RABBITMQ_PASS, KAFKA_BOOTSTRAP_SERVERS, etc.) before launching the MCP client.

affects: >=0.1.0

Errors

Common errors & fixes

Error: Cannot find module '@confluentinc/kafka-javascript'

Missing peer dependency for Kafka.

fix

Run 'npm install @confluentinc/kafka-javascript' in the project directory or globally.

Error: ENOENT: no such file or directory, stat '/path/to/schemas'

The --schemas path does not exist or is relative.

fix

Provide an absolute path to the schemas directory, e.g., --schemas $(pwd)/schemas.

Error: Connection refused to RabbitMQ management API on localhost:15672

RabbitMQ management plugin is not enabled or RabbitMQ is not running.

fix

Enable the management plugin: 'rabbitmq-plugins enable rabbitmq_management' and ensure RabbitMQ is started.

Upgrade

Version history

0.5.3latest on npm

Audit

Dependencies

@confluentinc/kafka-javascriptoptionalRequired peer dependency for Kafka broker support; optional if only using RabbitMQ

Agent activity

9 hits · last 30 days

node

Amazon

Resources

githubhttps://github.com/LarsCowe/queue-pilot ↗

packagequeue-pilot ↗

homepagehttps://github.com/LarsCowe/queue-pilot#readme ↗