rabbitmq-mcp

Stackblaze fork of kenliao94/mcp-server-rabbitmq — a Model Context Protocol server that exposes RabbitMQ queue, exchange, and shovel management tools for LLM agents.

This fork is tailored for Kubero chat feature MCP integration: one long-lived Deployment serves every RabbitmqCluster add-on in a workload cluster. The kubero broker passes the target broker URI and access mode per request via HTTP headers.

See FORK.md for kubero-specific integration details.

Tools

In Kubero chat, tools are prefixed rmq__ (e.g. rmq__list_queues).

Write tools refuse on production / read-only add-ons (restricted mode).

Related MCP server: Systems Manager

Kubero deployment

args:
  - --transport
  - streamable-http
  - --connection-from-request
  - --streamable-http-host
  - 0.0.0.0
  - --streamable-http-port
  - "3010"

Per-request headers from the kubero broker:

• X-Kubero-DB-URI: amqp://user:pass@host:5672/ (URL-encoded credentials)

• X-Kubero-Access-Mode: restricted or unrestricted

Local development

pip install -r requirements.txt

# stdio + static broker (env vars or upstream CLI)
export RABBITMQ_HOST=localhost RABBITMQ_PORT=5672
export RABBITMQ_USERNAME=guest RABBITMQ_PASSWORD=guest
python main.py

# HTTP + connection-from-request (like the k8s Deployment)
python main.py \
  --transport streamable-http \
  --connection-from-request \
  --streamable-http-host 0.0.0.0 \
  --streamable-http-port 3010

Docker

docker build -t rabbitmq-mcp .
docker run -p 3010:3010 rabbitmq-mcp \
  --transport streamable-http \
  --connection-from-request \
  --streamable-http-host 0.0.0.0 \
  --streamable-http-port 3010

Image: ghcr.io/stackblaze/rabbitmq-mcp

License

Apache-2.0 (upstream). See LICENSE.