Skip to main content

CloudThinker thin wrapper over amq-mcp-server-rabbitmq: reads RABBITMQ_* env at startup, auto-connects to a default broker, and serves the broker's read tools (mutative tools opt-in) over stdio.

Project description

ct-rabbitmq-mcp-server

A thin CloudThinker wrapper over amq-mcp-server-rabbitmq (the AWS-maintained RabbitMQ MCP server). It makes that server auto-connect from environment variables instead of requiring a runtime initialize_connection tool call, so it drops into CloudThinker's env-injection connection model.

What it does

  • Reads RABBITMQ_* env vars at startup and connects a default broker.
  • Exposes the broker read tools by default; mutative tools only when RABBITMQ_ALLOW_MUTATIONS=true.
  • Never exposes upstream's initialize_connection / get_guideline tools.
  • Talks to the Management HTTP API and serves over stdio.

Run

uvx --from ct-rabbitmq-mcp-server@0.1.0 ct-rabbitmq-mcp-server

Environment

Var Required Default Purpose
RABBITMQ_HOST yes broker hostname
RABBITMQ_USERNAME yes management-API user
RABBITMQ_PASSWORD yes management-API password
RABBITMQ_USE_TLS no false true → HTTPS management API
RABBITMQ_MANAGEMENT_PORT no 15672 (443 if TLS) Management HTTP API port
RABBITMQ_ALLOW_MUTATIONS no false true → also register mutative tools
LOG_LEVEL no info mapped to FASTMCP_LOG_LEVEL

The connecting user needs the RabbitMQ management or administrator tag, and the broker needs the Management plugin (rabbitmq-plugins enable rabbitmq_management).

Tool surface (upstream amq-mcp-server-rabbitmq==2.2.4)

Read (14, always): rabbitmq_broker_list_queues, _list_exchanges, _list_vhosts, _get_queue_info, _get_exchange_info, _list_shovels, _get_shovel_info, _get_cluster_nodes_info, _list_connections, _list_consumers, _list_users, _is_in_alarm, _is_quorum_critical, _get_broker_definition.

Mutative (4, opt-in): rabbitmq_broker_delete_queue, _purge_queue, _delete_exchange, _update_definition.

Implementation notes (read before bumping the upstream pin)

This wrapper depends on two upstream internals, frozen by the exact pin amq-mcp-server-rabbitmq==2.2.4:

  1. import src.* — upstream ships its package under the top-level name src.
  2. Private registration methods — we call RabbitMQModule._RabbitMQModule__register_read_only_tools() (and __register_mutative_tools()) to register the tool sets without the critical/connect tools.

Upstream's RabbitMQAdmin builds its base URL with no port (hardcoded for Amazon MQ on 443). To support self-managed brokers on 15672, the wrapper folds the management port into the hostname (host:port).

When raising the upstream pin, re-verify both internals and the management-URL behavior.

License

Apache-2.0 (matching upstream).

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

ct_rabbitmq_mcp_server-0.1.1.tar.gz (8.4 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

ct_rabbitmq_mcp_server-0.1.1-py3-none-any.whl (9.8 kB view details)

Uploaded Python 3

File details

Details for the file ct_rabbitmq_mcp_server-0.1.1.tar.gz.

File metadata

  • Download URL: ct_rabbitmq_mcp_server-0.1.1.tar.gz
  • Upload date:
  • Size: 8.4 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.11.15

File hashes

Hashes for ct_rabbitmq_mcp_server-0.1.1.tar.gz
Algorithm Hash digest
SHA256 406d5f302f1d38a39ad9c5339e20f5809e99ad0a823b95ae26a4264352f25cf3
MD5 dab4d77658f7f2998fc98ad5b009ba7d
BLAKE2b-256 8939610b265b241344ae04b2267fb51d3982b993f592215b1db21c26a86f79a3

See more details on using hashes here.

File details

Details for the file ct_rabbitmq_mcp_server-0.1.1-py3-none-any.whl.

File metadata

File hashes

Hashes for ct_rabbitmq_mcp_server-0.1.1-py3-none-any.whl
Algorithm Hash digest
SHA256 982988d97bf1c6749c55501f67b1dceaa27d502fb4c5f2fbb0e03d94bd517b50
MD5 5043a667f06c83a558746542d43cce61
BLAKE2b-256 c1aec6f6b7eee87e4b1c258eb4b96dbac92310947d2cf4aeeb130353c844a96d

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page