diff options
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 }); + + |
