QueueConsumer

Source: src/Cloudflare/Queue/QueueConsumer.ts

A Cloudflare Queue Consumer that processes messages from a Queue.

Register a Worker as a consumer of a Queue. The Worker’s queue() handler will be invoked with batches of messages.

Registering a Consumer

Basic consumer

const queue = yield* Cloudflare.Queue("MyQueue");
const worker = yield* Cloudflare.Worker("Worker", { ... });

yield* Cloudflare.QueueConsumer("MyConsumer", {
  queueId: queue.queueId,
  scriptName: "my-worker",
});

Consumer with settings

yield* Cloudflare.QueueConsumer("MyConsumer", {
  queueId: queue.queueId,
  scriptName: "my-worker",
  settings: {
    batchSize: 50,
    maxRetries: 5,
    maxWaitTimeMs: 10000,
  },
});