Queue MCP
Model Context Protocol integration for Queue
Queue MCP
A message queue for asynchronous task processing, enabling reliable communication between distributed components.
Installation
npx @dotdo/mcp install queueTools
queue_create
Create a new message queue.
Tool Schema:
{
"name": "queue_create",
"description": "Create a new message queue.",
"inputSchema": {
"type": "object",
"properties": {
// Tool parameters
}
}
}queue_delete
Permanently remove the queue.
Tool Schema:
{
"name": "queue_delete",
"description": "Permanently remove the queue.",
"inputSchema": {
"type": "object",
"properties": {
// Tool parameters
}
}
}queue_send
Send a message to the queue.
Tool Schema:
{
"name": "queue_send",
"description": "Send a message to the queue.",
"inputSchema": {
"type": "object",
"properties": {
// Tool parameters
}
}
}queue_receive
Retrieve messages from the queue for processing.
Tool Schema:
{
"name": "queue_receive",
"description": "Retrieve messages from the queue for processing.",
"inputSchema": {
"type": "object",
"properties": {
// Tool parameters
}
}
}queue_acknowledge
Confirm successful processing of a message.
Tool Schema:
{
"name": "queue_acknowledge",
"description": "Confirm successful processing of a message.",
"inputSchema": {
"type": "object",
"properties": {
// Tool parameters
}
}
}queue_retry
Return a message to the queue for reprocessing.
Tool Schema:
{
"name": "queue_retry",
"description": "Return a message to the queue for reprocessing.",
"inputSchema": {
"type": "object",
"properties": {
// Tool parameters
}
}
}queue_purge
Remove all messages from the queue.
Tool Schema:
{
"name": "queue_purge",
"description": "Remove all messages from the queue.",
"inputSchema": {
"type": "object",
"properties": {
// Tool parameters
}
}
}queue_inspect
View messages without removing them from the queue.
Tool Schema:
{
"name": "queue_inspect",
"description": "View messages without removing them from the queue.",
"inputSchema": {
"type": "object",
"properties": {
// Tool parameters
}
}
}Resources
queue/created
Triggered when a new queue is created.
Resource URI: queue://created
queue/deleted
Triggered when queue is removed.
Resource URI: queue://deleted
queue/Message.sent
Triggered when a message is added to the queue.
Resource URI: queue://Message.sent
queue/Message.received
Triggered when a message is retrieved for processing.
Resource URI: queue://Message.received
queue/Message.acknowledged
Triggered when message processing is confirmed.
Resource URI: queue://Message.acknowledged
queue/Message.retried
Triggered when a message is returned for reprocessing.
Resource URI: queue://Message.retried
queue/purged
Triggered when all messages are removed from queue.
Resource URI: queue://purged
Usage with Claude Desktop
Add to claude_desktop_config.json:
{
"mcpServers": {
"queue": {
"command": "npx",
"args": ["-y", "@dotdo/mcp", "serve", "queue"]
}
}
}