#Alepha - Queue

#Installation

Part of the alepha package. Import from alepha/queue.

npm install alepha

#Overview

Message transport used under $job. Not an application-facing API.

There is no queue primitive. Declare background work with $job (alepha/api/jobs) and add AlephaApiJobsQueue when you want dispatch to travel through a broker instead of running in-process.

Delivery at this layer is at-most-once: a message is popped from the backend before the handler runs, so a handler error or a process crash loses it. There is no retry and no dead-letter queue here — $job supplies those with a DB-backed outbox and a reconciliation sweep. (Cloudflare Queues adds broker-level retry/DLQ, configured on the binding.)

Features:

• Consumers registered imperatively via WorkerProvider.register
• Polling worker loop with configurable concurrency and backoff
• Batch send where the backend supports it (QueueProvider.pushMany)
• Providers: Memory (dev), Redis (production), Cloudflare Queues

#API Reference

#Providers

• CloudflareQueueProvider — Cloudflare Queue provider.
• QueueCodec — Owns the on-the-wire shape of a queue message.
• WorkerdWorkerProvider — Cloudflare Workers queue consumer provider.