Queue

Reference doc for the sst.cloudflare.Queue component.

The Queue component lets you add a Cloudflare Queue to your app.

Constructor

sst.config.ts

const queue = new sst.cloudflare.Queue("MyQueue");

Properties

id

nodes

SDK

Send messages to the queue from your worker:

src/producer.ts

import { Resource } from "sst";

export default {
  async fetch(request, env) {
    await env.MyQueue.send({ message: "Hello" });
    return new Response("Message sent");
  }
};

Process messages from the queue:

src/consumer.ts

export default {
  async queue(batch) {
    for (const message of batch.messages) {
      console.log(message.body);
    }
  }
};

Examples

Create a queue

sst.config.ts

const queue = new sst.cloudflare.Queue("MyQueue");

Subscribe to a queue

sst.config.ts

const queue = new sst.cloudflare.Queue("MyQueue");

queue.subscribe("src/consumer.ts");

Link to a worker

sst.config.ts

const queue = new sst.cloudflare.Queue("MyQueue");

new sst.cloudflare.Worker("MyWorker", {
  handler: "src/producer.ts",
  link: [queue]
});