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.0.tar.gz (7.8 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.0-py3-none-any.whl (9.4 kB view details)

Uploaded Python 3

File details

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

File metadata

  • Download URL: ct_rabbitmq_mcp_server-0.1.0.tar.gz
  • Upload date:
  • Size: 7.8 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.0.tar.gz
Algorithm Hash digest
SHA256 c2deeeb11a4c0686035b5417f2d204f6bcf24c3f3f510da821f68daf0526c936
MD5 8e77ae6210acae1297676ee39e069fc9
BLAKE2b-256 c8b17e1d60f2ce23f6b1f6cdc8bf1d277d13e934e7c1c5b2ca668adcad6131e0

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for ct_rabbitmq_mcp_server-0.1.0-py3-none-any.whl
Algorithm Hash digest
SHA256 7af4ea678a01b19da462ffbb66b3646a813936303d9258f64dd23ce520d525a9
MD5 f4e7101a2fe7f8ee03a601836bbbc778
BLAKE2b-256 3777e35339ffdbd23f6fb265e6fd64a808f5b6db8550e4858fbbbc99a3710512

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