diff --git a/apps/web/src/lib/queue.ts b/apps/web/src/lib/queue.ts new file mode 100644 index 0000000..98ea40e --- /dev/null +++ b/apps/web/src/lib/queue.ts @@ -0,0 +1,13 @@ +import { Queue } from "bullmq"; +import { getRedis } from "./redis"; + +let queue: Queue | null = null; + +export function getQueue(): Queue { + if (!queue) { + queue = new Queue("codeboard:generate", { + connection: getRedis(), + }); + } + return queue; +}