{"name":"io.github.LarsCowe/queue-pilot","slug":"larscowe-queue-pilot","title":"Queue Pilot","description":"MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation","url":"https://mcp.market/server/larscowe-queue-pilot","rating":null,"grade":"C","score":55,"certified":false,"status":"active","category":"other","tags":[],"presence":{"score":3,"stars":null,"forks":null,"downloads_week":null,"last_push_at":null,"license":"MIT"},"uptime":null,"claimed":false,"transport":"npm","callable_via_gateway":false,"default_price_micros":0,"repository":"https://github.com/LarsCowe/queue-pilot","website":"https://github.com/LarsCowe/queue-pilot#readme","version":"0.5.1","remotes":[],"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"}]}],"tools":[{"name":"check_health","description":"Check broker health status. Returns ok or failed with reason.","write_action":false,"price_micros":0,"input_schema":null},{"name":"create_queue","description":"Create a new queue. Idempotent if settings match; errors if the queue exists with different settings.","write_action":true,"price_micros":0,"input_schema":null},{"name":"delete_queue","description":"Delete a queue.","write_action":true,"price_micros":0,"input_schema":null},{"name":"get_overview","description":"Get cluster overview: version info, message rates, queue totals, and object counts.","write_action":false,"price_micros":0,"input_schema":null},{"name":"get_queue","description":"Get detailed information about a specific queue","write_action":false,"price_micros":0,"input_schema":null},{"name":"get_schema","description":"Get the full definition of a specific schema","write_action":false,"price_micros":0,"input_schema":null},{"name":"inspect_queue","description":"View messages in a queue and validate each against its schema","write_action":false,"price_micros":0,"input_schema":null},{"name":"list_connections","description":"List all client connections to the broker.","write_action":false,"price_micros":0,"input_schema":null},{"name":"list_consumers","description":"List all consumers connected to queues in a scope.","write_action":false,"price_micros":0,"input_schema":null},{"name":"list_queues","description":"List all queues with message counts","write_action":false,"price_micros":0,"input_schema":null},{"name":"list_schemas","description":"List all loaded message schemas","write_action":false,"price_micros":0,"input_schema":null},{"name":"peek_messages","description":"View messages in a queue without consuming them","write_action":false,"price_micros":0,"input_schema":null},{"name":"publish_message","description":"Publish a message to an exchange. Optionally validates against a schema before publishing — if validation fails, the message is NOT sent.","write_action":true,"price_micros":0,"input_schema":null},{"name":"purge_queue","description":"Remove all messages from a queue. Returns the number of messages purged.","write_action":true,"price_micros":0,"input_schema":null},{"name":"validate_message","description":"Validate a JSON message against a schema","write_action":false,"price_micros":0,"input_schema":null}],"scan":{"score":55,"grade":"C","scanned_at":"2026-09-28T14:28:05.919Z","report":{"scannerVersion":"0.1.10","scannedAt":"2026-09-28T14:28:05.898Z","components":{"code":{"score":25,"max":25,"notes":["71 source files scanned"]},"reliability":{"score":-1,"max":20,"notes":["no gateway calls yet and no remote to probe"]},"poisoning":{"score":-1,"max":15,"notes":["tools not inspected (local package is not executed); not counted"]},"auth":{"score":6,"max":15,"notes":["static API keys via environment variables"]},"maintenance":{"score":3,"max":15,"notes":["repository not readable: repo not found"]},"identity":{"score":2,"max":10,"notes":["no repository or website to verify"]}},"findings":[],"inputs":{"packages":[{"registryType":"npm","identifier":"queue-pilot","version":"0.5.1","found":true,"license":"MIT","hasInstallScripts":false,"dependencyCount":4,"publishedAt":"2026-02-14T12:22:32.339Z","repositoryUrl":"git+https://github.com/LarsCowe/queue-pilot.git"}],"repo":{"found":false,"owner":"LarsCowe","repo":"queue-pilot","error":"repo not found"},"icon":{"url":null,"source":"none"},"presence":{"stars":null,"forks":null,"downloadsWeek":null,"license":"MIT","lastPushAt":null,"score":3}}}},"grade_history":[],"reviews":[]}