Cloudflare Queue

Tip

This page is best viewed through the site search or through the AI.

This example creates a Cloudflare Queue with a producer and consumer worker.

sst.config.ts

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

queue.subscribe("consumer.ts");

const producer = new sst.cloudflare.Worker("Producer", {
  handler: "producer.ts",
  link: [queue],
  url: true,
});

consumer.ts

export default {
  async queue(batch, env) {
    for (const message of batch.messages) {
      console.log("Processing message:", message.body);
    }
  },
};

producer.ts

import { Resource } from "sst";

export default {
  async fetch() {
    await Resource.MyQueue.send({ hello: "world" });
    return new Response("Message sent!");
  },
};

View the full example.