mcp-rabbitmq mcp

v1.0.1 · MCP Tool · messaging · registry.pascalai.org

RabbitMQ Management HTTP API — queues, exchanges, messages, connections. Uses the management plugin REST API (port 15672 by default).

rabbitmqamqpmessagingqueuesevents

Input Parameters

Parameter	Type	Description
operationrequired	string	Operation to perform. One of: `list_queues`, `get_queue`, `create_queue`, `delete_queue`, `purge_queue`, `publish`, `get_messages`, `list_exchanges`, `list_vhosts`, `list_connections`, `overview`.
hostrequired	string	RabbitMQ host (default: localhost). Default: `localhost`.
portoptional	integer	Management API port (default: 15672). Default: `15672`.
usernameoptional	string	Username (default: guest). Default: `guest`.
passwordoptional	string	Password (default: guest). Default: `guest`.
vhostoptional	string	Virtual host (default: /). Default: `/`.
queueoptional	string	Queue name.
exchangeoptional	string	Exchange name (default: amq.default for publish).
routingKeyoptional	string	Routing key (usually equals queue name for default exchange).
bodyoptional	string	Message body or queue definition JSON.
countoptional	integer	Number of messages to get (default: 1). Default: `1`.
durableoptional	boolean	Durable queue (default: true). Default: `True`.
autoDeleteoptional	boolean	Auto-delete queue when unused (default: false). Default: `False`.

Output Fields

Field	Type	Description
ok	boolean
status	string
data	object
error	string

Examples

List queues

// Input
{
  "operation": "list_queues",
  "host": "rabbitmq"
}

// Output
{
  "ok": true
}

Publish a message

// Input
{
  "operation": "publish",
  "host": "rabbitmq",
  "routingKey": "tasks",
  "body": "{\"task\":\"send_report\"}"
}

// Output
{
  "ok": true
}

Install & Discovery

Install

ppm install mcp-rabbitmq

Get JSON Schema

GET /v1/packages/mcp-rabbitmq/1.0.1/schema

Discover by keyword

GET /v1/mcp/discover?q=rabbitmq

Discovery hint: Install with ppm install mcp-rabbitmq or invoke remotely via POST /v1/invoke/mcp-rabbitmq on the MCP Service.

PascalAI Usage

uses toolslib;
var Tool := LoadTool('mcp-rabbitmq');
var R := Tool.Call(JsonObj(['operation','list_queues','host','localhost']));
Writeln(R.ToJSON);