diff options
| author | MohamedBassem <me@mbassem.com> | 2024-02-06 17:00:26 +0000 |
|---|---|---|
| committer | MohamedBassem <me@mbassem.com> | 2024-02-06 17:00:26 +0000 |
| commit | e035c2fd1067a06d4774c64ae54548f664490f9d (patch) | |
| tree | 90d884e87b0bc24c55a851deca40fdafa9e11bb4 /shared/queues.ts | |
| parent | 7c262a2920bfde6fb26c66f22632ec016d9dd137 (diff) | |
| download | karakeep-e035c2fd1067a06d4774c64ae54548f664490f9d.tar.zst | |
Init package and start bullmq workers
Diffstat (limited to 'shared/queues.ts')
| -rw-r--r-- | shared/queues.ts | 10 |
1 files changed, 10 insertions, 0 deletions
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 }); + + |