모델 Context Protocol (MCP)에 대한 AMQP 운송 구현은 MCP 서버와 클라이언트가 RabbitMQ와 같은 AMQP 메시지 브로커를 통해 통신 할 수 있습니다.

혜택

• Reduced Complexity: 메시지 브로커는 보장된 납품, 자동적인 화물, 과실 취급 및 dead-letter queue (DLQ) 관리를 취급합니다
• ** 결함 허용 ** : 메시지는 persisted, 그래서 MCP 서버가 실패하면, 요청은 한 번 서버가 복구 할 수 있습니다 -Easy 확장: 더 많은 MCP 서버 인스턴스를 Exchange에 추가 큐를 바인딩하여 자동 로드밸런스 요청 추가
• Extensibility: 분석, 데이터 호수 저장, 사용자 지정 난간, 보안 정책 및 기존 기업 메시지 버스 인프라와 원활한 통합을 위한 메시지 흐름으로 탭

특징

• AMQP Transport Layer: AMQP 0.9.1 및 AMQP 1.0 프로토콜을 통해 MCP 운송의 전체 구현
• 클라이언트 및 서버 지원: 둘 다 ClientAMQPTransport 및 ServerAMQPTransport AMQP 0.9.1 클래스, 플러스 ClientAMQP10Transport 및 ServerAMQP10Transport AMQP 1.0
• **CLI 어댑터 ** : AMQP (both 프로토콜)를 사용하여 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';