import { Queue } from "@anabranch/queue";
import { createRedis } from "@anabranch/queue-redis";

const connector = createRedis({
  connection: "redis://localhost:6379",
  prefix: "my-app",
  queues: {
    orders: { maxAttempts: 3, deadLetterQueue: "orders-dlq" },
  },
});
const queue = await Queue.connect(connector).run();

await queue.send("orders", { orderId: "123", total: 99 }).run();