poly-queue-mcp

Unified MCP server for message queue management. Provides Model Context Protocol tools for interacting with Redis Streams, RabbitMQ, and NATS messaging systems.

Table of Contents

• Overview
• Adapters
  • Redis Streams (8 tools)
  • RabbitMQ (9 tools)
  • NATS (8 tools)
• Requirements
• Configuration
  • Redis
  • RabbitMQ
  • NATS
• Installation
• Usage
• Security Considerations
• License

Overview

poly-queue-mcp exposes message queue capabilities through the Model Context Protocol (MCP), enabling AI assistants and other MCP clients to manage message queues, publish/subscribe to topics, and monitor queue health across multiple messaging platforms.

Adapters

Redis Streams (8 tools)

Stream-based messaging with Redis:

• redis_xadd - Add an entry to a stream

• redis_xread - Read entries from streams

• redis_xrange - Get a range of entries from a stream

• redis_xlen - Get the length of a stream

• redis_xinfo - Get information about a stream

• redis_xgroup_create - Create a consumer group

• redis_xreadgroup - Read from a consumer group

• redis_xack - Acknowledge processed messages

RabbitMQ (9 tools)

Enterprise message broker via Management API:

• rabbitmq_queues - List all queues

• rabbitmq_queue - Get queue details

• rabbitmq_exchanges - List all exchanges

• rabbitmq_publish - Publish a message

• rabbitmq_get - Get messages from queue (non-destructive)

• rabbitmq_purge - Purge all messages from queue

• rabbitmq_overview - Get RabbitMQ overview

• rabbitmq_connections - List all connections

• rabbitmq_channels - List all channels

NATS (8 tools)

High-performance messaging with JetStream support:

• nats_publish - Publish a message to a subject

• nats_request - Send request and wait for reply

• nats_subscribe - Subscribe and receive messages

• nats_stream_list - List JetStream streams

• nats_stream_info - Get stream information

• nats_consumer_list - List consumers for a stream

• nats_server_info - Get NATS server info

• nats_account_info - Get account info

Requirements

• Deno runtime

• Redis with Streams support (for Redis tools)

• RabbitMQ with Management Plugin (for RabbitMQ tools)

• NATS CLI (for NATS tools)

Configuration

Redis

export REDIS_URL=localhost:6379

RabbitMQ

export RABBITMQ_URL=http://localhost:15672
export RABBITMQ_USER=guest
export RABBITMQ_PASS=guest

NATS

export NATS_URL=nats://localhost:4222

Installation

git clone https://github.com/hyperpolymath/poly-queue-mcp
cd poly-queue-mcp
npm install
npm run build

Usage

Run as MCP server:

deno run --allow-run --allow-read --allow-env --allow-net main.js

Or use the systemd service:

systemctl --user enable poly-queue-mcp
systemctl --user start poly-queue-mcp

Security Considerations

• Use authentication for all queue connections

• Enable TLS for production deployments

• Avoid exposing management APIs publicly

• Use least-privilege credentials

License

MIT