Queue

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

import { Resource } from "sst";

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

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

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

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

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

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

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