Topics

Create a topic and add 2 endpoints

import { Client } from "@upstash/qstash";

const client = new Client({ token: "<QSTASH_TOKEN>" });
const topics = client.topics();
await topics.addEndpoints({
  name: "topic_name",
  endpoints: [
    { url: "https://my-endpoint-1" },
    { url: "https://my-endpoint-2" },
  ],
});

Get topic by name

import { Client } from "@upstash/qstash";

const client = new Client({ token: "<QSTASH_TOKEN>" });
const topics = client.topics();
const topic = await topics.get("topicName");
console.log(topic.name, topic.endpoints);

List topics

import { Client } from "@upstash/qstash";

const client = new Client({ token: "<QSTASH_TOKEN>" });
const allTopics = await client.topics.list();
for (const topic of allTopics) {
  console.log(topic.name, topic.endpoints);
}

Remove an endpoint from a topic

import { Client } from "@upstash/qstash";

const client = new Client({ token: "<QSTASH_TOKEN>" });
const topics = client.topics();
await topics.removeEndpoints({
  name: "topic_name",
  endpoints: [{ url: "https://my-endpoint-1" }],
});

Delete a topic

import { Client } from "@upstash/qstash";

const client = new Client({ token: "<QSTASH_TOKEN>" });
const topics = client.topics();
await topics.delete("topicName");