Examples

The producer uses send on a queue_producer binding; the consumer is the queue handler on the same Worker. Put the platform queue.id in the binding, then oc types / oc run.

export default {
  async fetch(_request: Request, env: Env): Promise<Response> {
    await env.QUEUE.send({ hello: "world" });
    await env.QUEUE.sendBatch([{ body: { hello: "batch" } }]);
    return new Response("queued");
  },
  async queue(batch: MessageBatch<{ hello: string }>): Promise<void> {
    for (const message of batch.messages) {
      console.log(message.body);
      message.ack();
    }
  },
} satisfies ExportedHandler<{ QUEUE: Queue }>;

{
  "name": "queue-app",
  "main": "src/index.ts",
  "bindings": {
    "QUEUE": { "type": "queue_producer", "id": "<queue.id>" }
  }
}

send / sendBatch, contentType, delaySeconds, ack / retry match the Queues JavaScript APIs. Durability is local scheduler.sqlite. Delivery is at-least-once. Global FIFO and exactly-once are not provided. Create the queue: Get started.