Developer · Local MCP server

Queue Pilot

MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation.

Visit Queue Pilot's website

What the MCP Registry states

The entry as published to the official MCP Registry (read 2026-10-04), latest version.

Registry name
io.github.LarsCowe/queue-pilot
Version
0.5.1
Status
Active
Category
developer
Transport
stdio (local process)
Package
npm
Published
2026-02-14
Updated
2026-02-14
Publisher
LarsCowe (GitHub)
Website
github.com/LarsCowe/queue-pilot#readme
Repository
github.com/LarsCowe/queue-pilot
Source
Registry API entry

Packages

RegistryPackageVersionTransportEnvironment variables
npmruntime: npxqueue-pilot0.5.1stdioRABBITMQ_URL, RABBITMQ_USER (secret), RABBITMQ_PASS (secret), KAFKA_BROKERS, KAFKA_CLIENT_ID, KAFKA_SASL_MECHANISM, KAFKA_SASL_USERNAME (secret), KAFKA_SASL_PASSWORD (secret)

How to connect Queue Pilot

Queue Pilot runs locally from a Node.js package published to the npm registry: queue-pilot version 0.5.1. It speaks MCP over stdio, so the client starts it as a program and talks to it through standard input and output. It needs Node.js; clients usually start it with npx — the usual command is npx -y queue-pilot@0.5.1. It reads these environment variables: RABBITMQ_URL, RABBITMQ_USER (secret), RABBITMQ_PASS (secret), KAFKA_BROKERS, KAFKA_CLIENT_ID, KAFKA_SASL_MECHANISM, KAFKA_SASL_USERNAME (secret) and KAFKA_SASL_PASSWORD (secret); set them in the client's configuration for this server. Required arguments: --schemas.

In the mcpServers JSON format that many desktop and editor MCP clients read, the entry looks like this (placeholders in angle brackets):

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "queue-pilot@0.5.1"
      ],
      "env": {
        "RABBITMQ_URL": "<value>",
        "RABBITMQ_USER": "<secret>",
        "RABBITMQ_PASS": "<secret>",
        "KAFKA_BROKERS": "<value>",
        "KAFKA_CLIENT_ID": "<value>",
        "KAFKA_SASL_MECHANISM": "<value>",
        "KAFKA_SASL_USERNAME": "<secret>",
        "KAFKA_SASL_PASSWORD": "<secret>"
      }
    }
  }
}

Derived from the registry entry, not tested here. What the server does, and on what terms, is set by its publisher; check its repository or website before giving it access to your accounts or files. How to add an MCP server to an assistant · Before you connect

More developer servers

All 6,250 →
ServerRunsEndpoint or package
QueryPilotSafe SQL gateway for AI agents: SELECT-only validation, access policies, masking, audit trail, evals.Local · stdioPyPI: querypilot
QueryshieldSecure SQL proxy for AI agents — NL→SQL, AST safety, per-agent RLS, audit log.Local · stdioPyPI: queryshield-mcp
QueryWeaverAn MCP server for Text2SQL: transforms natural language into SQL using graph schema understanding.Local · HTTPOCI image (Docker): docker.io/falkordb/queryweaver:0.0.11
QuestDB Web Console MCP ServerConnects coding agents to a running QuestDB Web Console: notebook cells, SQL queries, and charts.Local · stdionpm: @questdb/mcp-server-questdb
Quick Html Share MCPShare AI-generated HTML from your coding agent. Unguessable URL + viewer analytics.Local · stdionpm: quick-html-share-mcp
QuickBooks OnlineQuickBooks Online MCP server: invoices, bills, customers, vendors, employees, and accounts.Local · stdionpm: @mindstone/mcp-server-quickbooks
QuickerSpot MCP ServerServidor MCP do QuickerSpot para vinhetas, rádio indoor e sonorização comercial com IA.Local · stdioPyPI: quickerspot-mcp
Quiet FailuresOpen weekly security base rates (CC BY 4.0), plus live DMARC, takeover and WHOIS checks.Remote · HTTPmcp.quietfailures.com