Queue Pilot

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