RabbitMQ

What is mcp-server-rabbitmq?

mcp-server-rabbitmq is a Model Context Protocol (MCP) server implementation specifically designed for RabbitMQ operations. It allows AI agents to interact with and manage RabbitMQ message brokers, providing a bridge between AI capabilities and message queue management.

How to use mcp-server-rabbitmq?

mcp-server-rabbitmq can be installed and used in several ways:

• Smithery: Automatic installation for Claude Desktop via Smithery using npx -y @smithery/cli install @kenliao94/mcp-server-rabbitmq --client claude.
• Online: Try it directly via the Smithery online platform at https://smithery.ai/server/@kenliao94/mcp-server-rabbitmq.
• PyPI: Integrate into your MCP client configuration using uvx with mcp-server-rabbitmq@latest and providing RabbitMQ connection details (host, port, username, password, TLS).
• From Source: Clone the repository and run using uv with the --directory flag and RabbitMQ connection parameters.

Key Features of mcp-server-rabbitmq

• AI Agent Management: Enables AI agents to manage RabbitMQ message brokers by wrapping admin APIs as MCP tools.
• Message-Level Interaction: Utilizes Pika for interacting with RabbitMQ at the message level.
• Dynamic Broker Connection: Allows specifying a different RabbitMQ broker mid-conversation.
• Streamable HTTP Support: Supports streamable HTTP with FastMCP's BearerAuthProvider for remote server setup.
• Seamless Integration: Available on PyPI for easy integration with MCP clients using uvx.

Use Cases of mcp-server-rabbitmq

• Automated Message Queue Management: AI agents can automate tasks like creating/deleting queues, exchanging messages, and managing bindings.
• Intelligent Monitoring: AI can monitor RabbitMQ activity and trigger actions based on message patterns or broker status.
• Dynamic Configuration: AI can dynamically reconfigure RabbitMQ connections or settings based on operational needs.
• Integration with AI Workflows: Incorporate RabbitMQ operations directly into AI-driven automation workflows.

FAQ about mcp-server-rabbitmq

• What is MCP? MCP stands for Model Context Protocol, which is a protocol for AI models to interact with external tools and services.
• Can I connect to multiple RabbitMQ brokers? Yes, you can specify a different RabbitMQ broker to connect to mid-conversation.
• Does it support secure connections? Yes, it supports TLS (AMQPS) for secure connections to RabbitMQ.
• How can I contribute? You can contribute by setting up a development environment, running tests, and ensuring code quality using ruff.

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>",
            "--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.