From e035c2fd1067a06d4774c64ae54548f664490f9d Mon Sep 17 00:00:00 2001 From: MohamedBassem Date: Tue, 6 Feb 2024 17:00:26 +0000 Subject: Init package and start bullmq workers --- shared/queues.ts | 10 ++++++++++ 1 file changed, 10 insertions(+) create mode 100644 shared/queues.ts (limited to 'shared/queues.ts') diff --git a/shared/queues.ts b/shared/queues.ts new file mode 100644 index 00000000..4303eaa2 --- /dev/null +++ b/shared/queues.ts @@ -0,0 +1,10 @@ +import { Queue } from "bullmq"; + +export const queueConnectionDetails = { + host: process.env.REDIS_HOST || "localhost", + port: parseInt(process.env.REDIS_PORT || "6379"), +}; + +export const LinkCrawlerQueue = new Queue("link_crawler_queue", { connection: queueConnectionDetails }); + + -- cgit v1.2.3-70-g09d2