RabbitMQ MCP Server

  • src
  • mcp_server_rabbitmq
from typing import Annotated from pydantic import BaseModel, Field class Enqueue(BaseModel): message: Annotated[str, Field(description="The message to publish")] queue: Annotated[str, Field(description="The name of the queue")] class Fanout(BaseModel): message: Annotated[str, Field(description="The message to publish")] exchange: Annotated[str, Field(description="The name of the exchange")]