rwsdk-cloudflare-queues

What problem does it solve?

Cloudflare Queues enable background task processing in rwsdk without blocking user requests and provide reliable, batched processing for asynchronous work.

Core Features & Use Cases

• Queue creation and management with wrangler
• Support for direct, R2, and KV message patterns to handle varying payloads
• Batch consumption and multi-queue orchestration for separation of concerns
• Message routing by type within or across queues
• Suitable for emails, payments, AI processing, image and video processing tasks

Quick Start

1. Create a queue: npx wrangler queues create my-queue-name
2. Configure wrangler.jsonc: { "queues": { "producers": [ { "binding": "QUEUE", "queue": "my-queue-name" } ], "consumers": [ { "queue": "my-queue-name", "max_batch_size": 10, "max_batch_timeout": 5 } ] } }
3. After updating: Run pnpm generate
4. Update Worker Export: export default { fetch: app.fetch, async queue(batch) { for (const message of batch.messages) { // Handle message } }, } satisfies ExportedHandler<Env>;