Rabbitmq Masstransit MCP

RabbitMQ MassTransit MCP服务器

RabbitMQ的MCP（模型上下文协议）服务器 MassTransit智能 --错误队列解析、故障分析和消息重新发布。

为跨团队调试异步消息传递问题而构建。NET微服务。通过了解MassTransit惯例，超越了基本的队列管理： _error/_skipped 队列、消息信封格式和故障消息解析。

特性

• 18工具 通过Claude Code实现完整的RabbitMQ管理
• MassTransit感知：自动检测和解析 _error/_skipped 队列、故障信封和消息类型URNs
• 解析错误输出：异常类型、消息、堆栈跟踪、消费者类型、重试计数和原始有效载荷——从中提取 MT-Fault-* 消息头
• 从错误重新发布：杀手级功能——获取故障消息并重新发布以进行重新处理
• 安全默认值：默认情况下禁用可变工具，对破坏性操作进行两步确认

快速入门

1.添加到您的Claude代码配置中 (~/.claude.json 或项目 .claude.json):

{
  "mcpServers": {
    "rabbitmq": {
      "command": "npx",
      "args": ["-y", "@stevepic95/rabbitmq-masstransit-mcp@latest"],
      "env": {
        "RABBITMQ_HOST": "your-rabbitmq-host",
        "RABBITMQ_USERNAME": "your-username",
        "RABBITMQ_PASSWORD": "your-password"
      }
    }
  }
}

2.重新启动克劳德代码 加载新的MCP服务器。

3.开始使用它。 问克劳德这样的问题：

• *“是否有包含消息的错误队列？”*
• *“显示提交订单错误队列中的故障”*
• *“哪些队列没有消费者？”*
• *“报告队列中有多少条消息？”*

就是这样。13个只读工具立即可用，不需要任何标志。

要启用写入操作（清除、删除、发布、重新发布），请设置 "ALLOW_MUTATIVE_TOOLS": "true" 在env配置中。

安装

npx @stevepic95/rabbitmq-masstransit-mcp@latest

Claude代码配置

添加到您的 .claude.json 在...之下 mcpServers:

{
  "mcpServers": {
    "rabbitmq": {
      "command": "npx",
      "args": ["-y", "@stevepic95/rabbitmq-masstransit-mcp@latest"],
      "env": {
        "RABBITMQ_HOST": "your-rabbitmq-host",
        "RABBITMQ_PORT": "15672",
        "RABBITMQ_USERNAME": "your-username",
        "RABBITMQ_PASSWORD": "your-password",
        "RABBITMQ_VHOST": "/",
        "RABBITMQ_SSL": "false",
        "ALLOW_MUTATIVE_TOOLS": "false"
      }
    }
  }
}

对于当地发展：

{
  "mcpServers": {
    "rabbitmq": {
      "command": "node",
      "args": ["/path/to/rabbitmq-masstransit-mcp/dist/index.js"],
      "env": {
        "RABBITMQ_HOST": "localhost",
        "RABBITMQ_USERNAME": "guest",
        "RABBITMQ_PASSWORD": "guest"
      }
    }
  }
}

配置

您还可以通过CLI标志启用变异工具： --allow-mutative-tools

工具

只读（13个工具）-始终可用

可变（5个工具）-需要 ALLOW_MUTATIVE_TOOLS=true

MassTransit智能

队列解析错误

peek_errors 不只是转储原始JSON，它读取 MT-Fault-* MassTransit在将消息移动到错误队列时附加的标头，为您提供调试故障所需的一切：

Queue: submit-order_error (3 messages)

Message 1:
  Faulted: 2026-02-15T14:30:05Z
  Reason: fault
  Message Type: MyApp.Messages.OrderSubmitted
  Consumer: MyApp.Consumers.SubmitOrderConsumer
  Exception: Microsoft.Data.SqlClient.SqlException - "Arithmetic overflow error converting numeric to data type numeric."
  Retry Count: 5
  Stack Trace:
    at Microsoft.Data.SqlClient.TdsParser.ThrowExceptionAndWarning(...)
    at MyApp.Data.OrderRepository.GetFees(Int32 orderId) in /src/OrderRepository.cs:line 35
    at MyApp.Services.OrderService.Process(Int32 id) in /src/OrderService.cs:line 51
    at MyApp.Consumers.SubmitOrderConsumer.Consume(ConsumeContext`1 context) in /src/SubmitOrderConsumer.cs:line 11
  Original Payload: { "orderId": "abc-123", "amount": 99.99 }
  Source Host: order-service-swrm-app1b-p02 / order-service (PID 1)
  Assembly: order-service v1.0.3.0 (.NET 8.0.8)

从错误重新发布（两步）

调试的最高价值工具。第一次呼叫预览消息：

> republish_from_error(errorQueue: "submit-order_error", count: 3)

Preview: 3 message(s) from "submit-order_error" ready to republish:
[... parsed fault details ...]

To republish these messages, call again with confirm=true and count=3.

第二次通话 confirm: true 实际消费和重新发布：

> republish_from_error(errorQueue: "submit-order_error", count: 3, confirm: true)

Republished 3/3 message(s) from "submit-order_error".

队列健康检查

快速概述所有队列中的潜在问题：

> get_queue_health()

⚠ Queues with NO consumers and messages (2):
  order-processing — 150 message(s)
  notification-sender — 42 message(s)

✗ Error queues with messages (3 queues, 89 total):
  submit-order_error — 45 message(s)
  payment-process_error — 32 message(s)
  email-send_error — 12 message(s)

△ High depth queues (>1000 messages, 1):
  analytics-events — 15234 message(s), 2 consumer(s)

需求

• Node.js>=18.0.0
• 启用管理插件的RabbitMQ（端口15672）

许可证

麻省理工学院