A Model Context Protocol server implementation for RabbitMQ operation.
Created 3 months ago
A Model Context Protocol server implementation for RabbitMQ operation.
What is A Model Context Protocol server implementation for RabbitMQ operation.?
This MCP server wraps admin APIs of a RabbitMQ broker as MCP tools. It uses Pika to interact with RabbitMQ to operate at the message level. You can specify a different RabbitMQ broker mid-conversation. Supports streamable HTTP with FastMCP's BearerAuthProvider and seamless integration with MCP clients.
Documentation
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
- 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
- Full feature parity with
rabbitmqadmin - Support RabbitMQ OAuth instead of basic authentication
Development# Setup Development Environment
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:
ruff check .
# Run formatter
ruff format .
License
This project is licensed under the Apache License 2.0 - see the LICENSE file for details.
Server Config
{
"mcpServers": {
"a-model-context-protocol-server-implementation-for-rabbitmq-operation.-server": {
"command": "npx",
"args": [
"a-model-context-protocol-server-implementation-for-rabbitmq-operation."
]
}
}
}