RabbitMQ MCP Server

What is RabbitMQ MCP Server about?

It provides an MCP‑compatible interface for RabbitMQ, exposing broker administration and message‑level actions as tools that can be invoked by AI agents.

How to use RabbitMQ MCP Server?

1. Install the package from PyPI (pip install mcp-server-rabbitmq) or run it directly with uvx/uv as shown in the README.
2. Start the server, passing connection parameters such as host, port, username, password, TLS flag, and optional admin‑API port.
3. In an MCP‑compatible client, reference the server under the mcpServers configuration, supplying the same arguments.
4. During a conversation the AI can call tools like list_queues, publish_message, or create_user to control the broker.

Key features of RabbitMQ MCP Server

• Admin API wrapping: All rabbitmqadmin commands are exposed as MCP tools.
• Message‑level operations: Publish, consume, acknowledge, and purge messages via Pika.
• Dynamic broker selection: Switch target RabbitMQ instance mid‑session.
• Streamable HTTP with BearerAuthProvider: Works with FastMCP for secure, token‑based access.
• One‑click deployment: Available on Smithery, PyPI, and as a UVX executable.

Use cases of RabbitMQ MCP Server

• Automating queue management (create/delete queues, set policies) from an AI assistant.
• Real‑time monitoring and troubleshooting of message flow via conversational interfaces.
• Integrating RabbitMQ control into larger AI‑driven workflow automation platforms.
• Deploying secure, authenticated RabbitMQ control planes for multi‑tenant environments.

FAQ from the RabbitMQ MCP Server

Q: Can I change the broker after the server has started? A: Yes, the MCP tools accept connection parameters, allowing the AI to point to a different host, port, or credential set during a session.

Q: Do I need TLS for the AMQP connection? A: Set --use-tls true when launching the server if your broker uses amqps; otherwise leave it false.

Q: How is authentication handled for the HTTP endpoint? A: The server uses FastMCP's BearerAuthProvider; configure your IdP and pass bearer tokens in client requests.

Q: Is there parity with rabbitmqadmin? A: Full parity is planned on the roadmap; current implementation covers the most common admin commands.

Q: Can I use OAuth instead of basic auth? A: OAuth support is on the roadmap; currently only username/password authentication is available.

RabbitMQ MCP Server

A Model Context Protocol server implementation for RabbitMQ operation.

Features

Manage your RabbitMQ message brokers using AI agent

This MCP servers wraps admin APIs of a RabbitMQ broker as MCP tools. It also uses Pika to interact with RabbitMQ to operate at the message level. You can also specify a different RabbitMQ broker that you want to connect to mid-conversation (default is configured during server initialization).

Supports streamable HTTP with FastMCP's BearerAuthProvider

You can start a remote RabbitMQ MCP server by configuring your own IdP and 3rd party authorization provider.

Seamless integration with MCP clients

The package is available on PyPI, you can use uvx without having to fork and build the MCP server locally first.

Installation

Smithery

To install RabbitMQ MCP Server for Claude Desktop automatically via Smithery:

npx -y @smithery/cli install @kenliao94/mcp-server-rabbitmq --client claude

Try it online

https://smithery.ai/server/@kenliao94/mcp-server-rabbitmq

PyPI

https://pypi.org/project/mcp-server-rabbitmq/

Use uvx directly in your MCP client config

{
    "mcpServers": {
      "rabbitmq": {
        "command": "uvx",
        "args": [
            "mcp-server-rabbitmq@latest",
            "--rabbitmq-host",
            "<hostname ex. test.rabbit.com, localhost>",
            "--port",
            "<port number ex. 5672>",
            "--username",
            "<rabbitmq username>",
            "--password",
            "<rabbitmq password>",
            "--api-port",
            "<port number for the admin API, default to 15671>"
            "--use-tls",
            "<true if uses amqps, false otherwise>"
        ]
      }
    }
}

From source

1. Clone this repository.

{
    "mcpServers": {
      "rabbitmq": {
        "command": "uv",
        "args": [
            "--directory",
            "/path/to/repo/mcp-server-rabbitmq",
            "run",
            "mcp-server-rabbitmq",
            "--rabbitmq-host",
            "<hostname ex. test.rabbit.com, localhost>",
            "--port",
            "<port number ex. 5672>",
            "--username",
            "<rabbitmq username>",
            "--password",
            "<rabbitmq password>",
            "--use-tls",
            "<true if uses amqps, false otherwise>"
        ]
      }
    }
}

Roadmap

1. Full feature parity with rabbitmqadmin
2. Support RabbitMQ OAuth instead of basic authentication

Development

Setup Development Environment

# Clone the repository
git clone https://github.com/kenliao94/mcp-server-rabbitmq.git
cd mcp-server-rabbitmq

# Install pre-commit hooks
pre-commit install

Running Tests

pytest

Code Quality

This project uses ruff for linting and formatting:

# Run linter
ruff check .

# Run formatter
ruff format .

License

This project is licensed under the Apache License 2.0 - see the LICENSE file for details.