@radzor/queue-worker

In-memory job queue with workers, retries, and dead-letter handling. No external dependencies.

Automationv0.1.0typescriptpythonServerqueueworkerjobsbackgroundasynctaskby Radzor

Install

$npx radzor@latest add queue-worker

⚠ Constraints: No external dependencies. In-memory only — jobs are lost on process restart. For persistent queues use Redis or a dedicated message broker. Concurrency controls parallel workers.

Inputs

Name	Type	Default	Description
concurrency	number	—	Max concurrent workers (default: 1)
maxRetries	number	—	Max retry attempts per job (default: 3)
retryDelay	number	—	Delay between retries in ms (default: 1000)

concurrencynumber

Max concurrent workers (default: 1)

maxRetriesnumber

Max retry attempts per job (default: 3)

retryDelaynumber

Delay between retries in ms (default: 1000)

{ "llm": { "constraints": "No external dependencies. In-memory only — jobs are lost on process restart. For persistent queues use Redis or a dedicated message broker. Concurrency controls parallel workers.", "usageExamples": "llm/examples.md", "integrationPrompt": "llm/integration.md" }, "name": "@radzor/queue-worker", "tags": [ "queue", "worker", "jobs", "background", "async", "task" ], "events": [ { "name": "onJobComplete", "payload": { "name": "string", "jobId": "string", "durationMs": "number" }, "description": "Fired when a job completes successfully." }, { "name": "onJobFailed", "payload": { "name": "string", "error": "string", "jobId": "string", "attempts": "number" }, "description": "Fired when a job fails after all retries." }, { "name": "onError", "payload": { "code": "string", "message": "string" }, "description": "Fired on queue error." } ], "inputs": [ { "name": "concurrency", "type": "number", "required": false, "description": "Max concurrent workers (default: 1)" }, { "name": "maxRetries", "type": "number", "required": false, "description": "Max retry attempts per job (default: 3)" }, { "name": "retryDelay", "type": "number", "required": false, "description": "Delay between retries in ms (default: 1000)" } ], "radzor": "1.0.0", "actions": [ { "name": "addJob", "params": [ { "name": "name", "type": "string", "description": "Job queue name." }, { "name": "payload", "type": "unknown", "description": "Serializable job data." } ], "returns": "string", "description": "Add a job to the queue. Returns the job ID." }, { "name": "process", "params": [ { "name": "name", "type": "string", "description": "Queue name to process." }, { "name": "handler", "type": "(payload: unknown) => Promise<unknown>", "description": "Async handler function." } ], "returns": "void", "description": "Register a worker handler for a queue. Call once at startup." }, { "name": "start", "params": [], "returns": "void", "description": "Start processing queued jobs." }, { "name": "stop", "params": [], "returns": "void", "description": "Stop processing and drain the queue gracefully." } ], "outputs": [ { "name": "jobResult", "type": "{ jobId: string; status: 'completed' | 'failed'; result?: unknown; error?: string }", "description": "Result of a completed or failed job." } ], "runtime": "server", "version": "0.1.0", "category": "automation", "languages": [ "typescript", "python" ], "description": "In-memory job queue with workers, retries, and dead-letter handling. No external dependencies.", "dependencies": { "packages": {} }, "composability": { "connectsTo": [ { "event": "onJobFailed", "description": "Alert on job processing failure", "compatibleWith": [ "@radzor/error-tracker.action.captureMessage.message", "@radzor/slack-bot.action.sendMessage.text", "@radzor/notification-hub.action.send.body" ] }, { "event": "onJobComplete", "description": "Log job completions", "compatibleWith": [ "@radzor/log-aggregator.action.info.message", "@radzor/event-tracker.action.track.eventName" ] } ] } }

@radzor/queue-worker

Install

Inputs

Outputs

Actions

Events

Composability

radzor.manifest.json

Version History