feat: add BullMQ queue singleton

This commit is contained in:
2001-01-01 00:00:00 +00:00
parent 41ac84378c
commit b7268c2fb6

13
apps/web/src/lib/queue.ts Normal file
View File

@@ -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;
}