DLQ

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

const client = new Client({ token: "<QSTASH_TOKEN>" });
const all_messages = [];
let cursor = null;
while (true) {
  const res = await client.dlq.listMessages({ cursor });
  all_messages.push(...res.messages);
  cursor = res.cursor;
  if (!cursor) {
    break;
  }
}

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

const client = new Client({ token: "<QSTASH_TOKEN>" });

// filter and paginate with top-level options
const res = await client.dlq.listMessages({
  count: 10,
  order: "latestFirst",
  filter: { url: "https://example.com" }
})

// fetch specific DLQ messages by ID
const res2 = await client.dlq.listMessages({
  dlqIds: ["dlq-id-1", "dlq-id-2"]
})

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

const client = new Client({ token: "<QSTASH_TOKEN>" });

// delete a single message
await client.dlq.delete("dlqId");

// delete multiple messages
await client.dlq.delete(["dlq-id-1", "dlq-id-2"]);

// delete with filters
let cursor: string | undefined;
do {
  const result = await client.dlq.delete({
    filter: { url: "https://example.com", responseStatus: 500 },
    cursor,
  });
  cursor = result.cursor;
} while (cursor);

// delete all DLQ messages
do {
  const result = await client.dlq.delete({ all: true, cursor });
  cursor = result.cursor;
} while (cursor);

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

const client = new Client({ token: "<QSTASH_TOKEN>" });

// retry a single message
await client.dlq.retry("dlqId");

// retry multiple messages
await client.dlq.retry(["dlq-id-1", "dlq-id-2"]);

// retry with filters
let cursor: string | undefined;
do {
  const result = await client.dlq.retry({
    filter: { queueName: "my-queue" },
    cursor,
  });
  cursor = result.cursor;
} while (cursor);