Connect

8 clients · secrets stay placeholders

JSON (mcpServers)Claude CodeCodexOpenCodeCursorVS CodeGemini CLIGoose

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "[email protected]",
        "--schemas",
        "--broker"
      ],
      "env": {
        "RABBITMQ_URL": "http://localhost:15672",
        "RABBITMQ_USER": "${RABBITMQ_USER}",
        "RABBITMQ_PASS": "${RABBITMQ_PASS}",
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "queue-pilot",
        "KAFKA_SASL_USERNAME": "${KAFKA_SASL_USERNAME}",
        "KAFKA_SASL_PASSWORD": "${KAFKA_SASL_PASSWORD}"
      }
    }
  }
}

claude mcp add queue-pilot -e "RABBITMQ_URL=http://localhost:15672" -e "RABBITMQ_USER=${RABBITMQ_USER}" -e "RABBITMQ_PASS=${RABBITMQ_PASS}" -e "KAFKA_BROKERS=localhost:9092" -e "KAFKA_CLIENT_ID=queue-pilot" -e "KAFKA_SASL_USERNAME=${KAFKA_SASL_USERNAME}" -e "KAFKA_SASL_PASSWORD=${KAFKA_SASL_PASSWORD}" -- npx -y [email protected] --schemas --broker

[mcp_servers.queue-pilot]
command = "npx"
args = ["-y", "[email protected]", "--schemas", "--broker"]
env = { "RABBITMQ_URL" = "http://localhost:15672", "RABBITMQ_USER" = "${RABBITMQ_USER}", "RABBITMQ_PASS" = "${RABBITMQ_PASS}", "KAFKA_BROKERS" = "localhost:9092", "KAFKA_CLIENT_ID" = "queue-pilot", "KAFKA_SASL_USERNAME" = "${KAFKA_SASL_USERNAME}", "KAFKA_SASL_PASSWORD" = "${KAFKA_SASL_PASSWORD}" }

{
  "$schema": "https://opencode.ai/config.json",
  "mcp": {
    "queue-pilot": {
      "type": "local",
      "command": [
        "npx",
        "-y",
        "[email protected]",
        "--schemas",
        "--broker"
      ],
      "enabled": true,
      "environment": {
        "RABBITMQ_URL": "http://localhost:15672",
        "RABBITMQ_USER": "{env:RABBITMQ_USER}",
        "RABBITMQ_PASS": "{env:RABBITMQ_PASS}",
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "queue-pilot",
        "KAFKA_SASL_USERNAME": "{env:KAFKA_SASL_USERNAME}",
        "KAFKA_SASL_PASSWORD": "{env:KAFKA_SASL_PASSWORD}"
      }
    }
  }
}

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "[email protected]",
        "--schemas",
        "--broker"
      ],
      "env": {
        "RABBITMQ_URL": "http://localhost:15672",
        "RABBITMQ_USER": "${RABBITMQ_USER}",
        "RABBITMQ_PASS": "${RABBITMQ_PASS}",
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "queue-pilot",
        "KAFKA_SASL_USERNAME": "${KAFKA_SASL_USERNAME}",
        "KAFKA_SASL_PASSWORD": "${KAFKA_SASL_PASSWORD}"
      }
    }
  },
  "deeplink": "cursor://anysphere.cursor-deeplink/mcp/install?name=queue-pilot&config=eyJjb21tYW5kIjoibnB4IiwiYXJncyI6WyIteSIsInF1ZXVlLXBpbG90QDAuNS4xIiwiLS1zY2hlbWFzIiwiLS1icm9rZXIiXSwiZW52Ijp7IlJBQkJJVE1RX1VSTCI6Imh0dHA6Ly9sb2NhbGhvc3Q6MTU2NzIiLCJSQUJCSVRNUV9VU0VSIjoiJHtSQUJCSVRNUV9VU0VSfSIsIlJBQkJJVE1RX1BBU1MiOiIke1JBQkJJVE1RX1BBU1N9IiwiS0FGS0FfQlJPS0VSUyI6ImxvY2FsaG9zdDo5MDkyIiwiS0FGS0FfQ0xJRU5UX0lEIjoicXVldWUtcGlsb3QiLCJLQUZLQV9TQVNMX1VTRVJOQU1FIjoiJHtLQUZLQV9TQVNMX1VTRVJOQU1FfSIsIktBRktBX1NBU0xfUEFTU1dPUkQiOiIke0tBRktBX1NBU0xfUEFTU1dPUkR9In19"
}

{
  "servers": {
    "queue-pilot": {
      "type": "stdio",
      "command": "npx",
      "args": [
        "-y",
        "[email protected]",
        "--schemas",
        "--broker"
      ],
      "env": {
        "RABBITMQ_URL": "http://localhost:15672",
        "RABBITMQ_USER": "${RABBITMQ_USER}",
        "RABBITMQ_PASS": "${RABBITMQ_PASS}",
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "queue-pilot",
        "KAFKA_SASL_USERNAME": "${KAFKA_SASL_USERNAME}",
        "KAFKA_SASL_PASSWORD": "${KAFKA_SASL_PASSWORD}"
      }
    }
  }
}

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "[email protected]",
        "--schemas",
        "--broker"
      ],
      "env": {
        "RABBITMQ_URL": "http://localhost:15672",
        "RABBITMQ_USER": "${RABBITMQ_USER}",
        "RABBITMQ_PASS": "${RABBITMQ_PASS}",
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "queue-pilot",
        "KAFKA_SASL_USERNAME": "${KAFKA_SASL_USERNAME}",
        "KAFKA_SASL_PASSWORD": "${KAFKA_SASL_PASSWORD}"
      }
    }
  }
}

extensions:
  "queue-pilot":
    enabled: true
    name: "queue-pilot"
    type: stdio
    cmd: "npx"
    args:
      - "-y"
      - "[email protected]"
      - "--schemas"
      - "--broker"
    envs:
      "RABBITMQ_URL": "http://localhost:15672"
      "RABBITMQ_USER": "${RABBITMQ_USER}"
      "RABBITMQ_PASS": "${RABBITMQ_PASS}"
      "KAFKA_BROKERS": "localhost:9092"
      "KAFKA_CLIENT_ID": "queue-pilot"
      "KAFKA_SASL_USERNAME": "${KAFKA_SASL_USERNAME}"
      "KAFKA_SASL_PASSWORD": "${KAFKA_SASL_PASSWORD}"
    timeout: 300

Placeholders to fill from your own secret store: ${RABBITMQ_USER}, ${RABBITMQ_PASS}, ${KAFKA_SASL_USERNAME}, ${KAFKA_SASL_PASSWORD}. The registry never accepts secret values.

This is a local package: the command runs on your machine.

Quality – / 100not scored

Not scored: fewer than three checks apply, usually because no remote answered a credential-free probe or the server is a local package.

protocoln/a · weight 25

n/a
protocol.modern, protocol.stateless, protocol.transport, protocol.list_ttlno remote answered a protocol handshake (not probed yet, unreachable, or local-only)

authorizationn/a · weight 15

n/a
auth.prm, auth.as_metadata, auth.cimdno remote uses OAuth
n/a
auth.secret_in_urlno templated URL

tool hygienen/a · weight 30

n/a
tools.descriptions, tools.description_length, tools.schemas, tools.annotations, tools.directory_hints, tools.token_cost, tools.api_dumptool list unknown (behind auth, not probed, or empty)

stabilityn/a · weight 15

n/a
stability.changes, stability.rug_pulltool list unknown

dependencies67 · weight 15

pass
deps.known_vulnsno known advisory in 98 resolved packages
fail
deps.mcp_sdk_version@modelcontextprotocol/sdk 1.30.1 has 1 known advisory (GHSA-6qxp-vccf-f47h); update @modelcontextprotocol/sdk to 1.31.0 or later
pass
deps.resolvable[email protected] resolved: 98 packages

Tool list unknown · checked 2026-10-19 10:20 UTC

Tool changes

No tool definition changes recorded. A server's first observation is its baseline; later probes record what changes.

Checks run on what our credential-free, read-only probes observe; tools are never called and no code audit is performed. How it is computed.

Trust 80 / 100

provenance90

livenessn/a

freshness45

hygiene100

+repository +namespace-matches-repo +website ~liveness-unmeasured -stale-247d

Derived from observable signals (official registry feed and our own credential-free probes); no code audit performed. How it is computed.

Dependencies

[email protected] npm97 dependencies, resolved · MCP SDK @modelcontextprotocol/sdk 1.30.1 · advisories checked 2026-10-19

advisory	severity	package	fixed in
GHSA-6qxp-vccf-f47hMCP TypeScript SDK: OAuth client could send credentials to an authorization server chosen by the MCP server	high	`@modelcontextprotocol/[email protected]`MCP SDK, direct	fixed in `1.31.0`

Dependency graphs from deps.dev; advisories from OSV.dev, including the GitHub Advisory Database and the PyPI Advisory Database; all CC BY 4.0. The graph is what a clean install of this version resolves today; nothing was installed or run. How it is checked.

Endpoints

package	registry	version	runtime	secrets
`queue-pilot`	npm	0.5.1	npx	`RABBITMQ_USER`, `RABBITMQ_PASS`, `KAFKA_SASL_USERNAME`, `KAFKA_SASL_PASSWORD`

Tools (0)

No tools observed. Local packages are never executed by the registry.

Schemas: list_tools.

Similar MCP servers

Official server.json

{
  "name": "io.github.LarsCowe/queue-pilot",
  "title": "Queue Pilot",
  "$schema": "https://static.modelcontextprotocol.io/schemas/2025-12-11/server.schema.json",
  "version": "0.5.1",
  "packages": [
    {
      "version": "0.5.1",
      "transport": {
        "type": "stdio"
      },
      "identifier": "queue-pilot",
      "runtimeHint": "npx",
      "registryType": "npm",
      "registryBaseUrl": "https://registry.npmjs.org",
      "packageArguments": [
        {
          "name": "--schemas",
          "type": "named",
          "valueHint": "filepath",
          "isRequired": true,
          "description": "Path to directory containing JSON Schema files"
        },
        {
          "name": "--broker",
          "type": "named",
          "valueHint": "string",
          "description": "Broker type: rabbitmq or kafka (default: rabbitmq)"
        }
      ],
      "environmentVariables": [
        {
          "name": "RABBITMQ_URL",
          "format": "string",
          "default": "http://localhost:15672",
          "description": "RabbitMQ Management API URL"
        },
        {
          "name": "RABBITMQ_USER",
          "format": "string",
          "default": "guest",
          "isSecret": true,
          "description": "RabbitMQ username"
        },
        {
          "name": "RABBITMQ_PASS",
          "format": "string",
          "default": "guest",
          "isSecret": true,
          "description": "RabbitMQ password"
        },
        {
          "name": "KAFKA_BROKERS",
          "format": "string",
          "default": "localhost:9092",
          "description": "Comma-separated Kafka broker addresses"
        },
        {
          "name": "KAFKA_CLIENT_ID",
          "format": "string",
          "default": "queue-pilot",
          "description": "Kafka client ID"
        },
        {
          "name": "KAFKA_SASL_MECHANISM",
          "format": "string",
          "description": "SASL mechanism: plain, scram-sha-256, scram-sha-512"
        },
        {
          "name": "KAFKA_SASL_USERNAME",
          "format": "string",
          "isSecret": true,
          "description": "SASL username"
        },
        {
          "name": "KAFKA_SASL_PASSWORD",
          "format": "string",
          "isSecret": true,
          "description": "SASL password"
        }
      ]
    }
  ],
  "repository": {
    "url": "https://github.com/LarsCowe/queue-pilot",
    "source": "github"
  },
  "websiteUrl": "https://github.com/LarsCowe/queue-pilot#readme",
  "description": "MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation"
}