モデルコンテキストプロトコル(MCP)のAMQPトランスポート実装で、MCPサーバーとクライアントがRabbitMQなどのAMQPメッセージブローカーに通信できるようにします。

利点

-Reduced Complexity:メッセージブローカーは、保証された配送、自動配送、エラー処理、およびデッドレターキュー(DLQ)管理を処理します

• 欠陥許容:メッセージは主張されます、従ってMCPサーバーが回復したらMCPサーバーが失敗すれば要求は償還することができます
• 容易なスケーリング: 取引所に追加のキューを結合するだけで、MCP サーバーインスタンスを追加できます。ブローカーは自動的にロードバランスリクエストを処理します。 -拡張性: 分析、データ湖ストレージ、カスタムガードレール、セキュリティポリシー、既存のエンタープライズメッセージバスインフラストラクチャとのシームレスな統合のためのメッセージフローをタップ

##特徴

-AMQPトランスポートレイヤ:AMQP 0.9.1およびAMQP 1.0プロトコル上のMCPトランスポートの完全な実装

• クライアント&サーバーサポート: ClientAMQPTransportと[ServerAMQPTransport]のクラスは、AMQP 0.9.1に加えて、[ClientAMQP10Transportと[ServerAMQP10Transport)
• CLI Adaptors:AMQP(両方のプロトコル)でstdioベースのMCPサーバー/クライアントをブリッジするコマンドラインツール

MCP AMQP Transport [beta]

AMQP transport implementation for the Model Context Protocol (MCP), enabling MCP servers and clients to communicate over AMQP message brokers like RabbitMQ.

Benefits

• Reduced Complexity: Message broker handles guaranteed delivery, automatic retries, error handling, and dead-letter queue (DLQ) management
• Fault Tolerance: Messages are persisted, so if an MCP server fails, requests can be redelivered once the server recovers
• Easy Scaling: Add more MCP server instances by simply binding additional queues to the exchange—the broker automatically load-balances requests
• Extensibility: Tap into message flows for analytics, data lake storage, custom guardrails, security policies, and seamless integration with existing enterprise message bus infrastructure

Features

• AMQP Transport Layer: Full implementation of MCP transport over AMQP 0.9.1 and AMQP 1.0 protocols
• Client & Server Support: Both ClientAMQPTransport and ServerAMQPTransport classes for AMQP 0.9.1, plus ClientAMQP10Transport and ServerAMQP10Transport for AMQP 1.0
• CLI Adaptors: Command-line tools to bridge stdio-based MCP servers/clients with AMQP (both protocols)
• Interceptor Framework: Base class for building message interceptors
• Flexible Configuration: Support for environment variables and direct configuration
• TLS Support: Secure connections with AMQPS

Installation

npm install -g @aws/mcp-amqp-transport

Usage

Using Transport Classes

You need to configure the following environment variables:

AMQP_HOSTNAME - AMQP broker hostname
AMQP_USERNAME - username for your broker
AMQP_PASSWORD - password for your broker
AMQP_PORT - AMQP broker port (default: 5672 for AMQP, 5671 for AMQPS) 
AMQP_USE_TLS - Use TLS connection (default: true)

Example:

export AMQP_HOSTNAME=localhost
export AMQP_PORT=5672
export AMQP_USERNAME=guest
export AMQP_PASSWORD=guest
export AMQP_USE_TLS=false

AMQP 0.9.1 Transport (Default)

Server Transport

import { Server } from '@modelcontextprotocol/sdk/server/index.js';
import { ServerAMQPTransport } from '@aws/mcp-amqp-transport';

const server = new Server(
  { name: 'my-server', version: '1.0.0' },
  { capabilities: {} }
);

// Configuration via environment variables
const transport = new ServerAMQPTransport({
  name: 'my-server',
  exchangeName: 'mcp-exchange'
  // hostname, port, username, password read from environment variables
});

await server.connect(transport);

Client Transport

import { Client } from '@modelcontextprotocol/sdk/client/index.js';
import { ClientAMQPTransport } from '@aws/mcp-amqp-transport';