queues

SKILL.md

Build reliable asynchronous message processing on Cloudflare Workers using Queues for background tasks, batch operations, and retry handling.

| Send single message | env.QUEUEBINDING.send(payload) | | Send batch | env.QUEUEBINDING.sendBatch([msg1, msg2]) | | Define consumer | async queue(batch: MessageBatch, env: Env) { ... } | | Access message body | batch.messages.map(msg => msg.body) | | Acknowledge message | Messages auto-ack unless handler throws |

| Retry message | throw new Error() in queue handler | | Get batch size | batch.messages.length |

Asynchronous message queues for reliable background processing. Load when offloading background tasks, batch processing messages, implementing retry logic with dead letter queues, rate limiting upstream APIs, or decoupling producers from consumers. Source: null-shot/cloudflare-skills.

View raw