use worker redis client when connect to the queue in queue-processor

2024-01-19 20:44:54 +08:00
parent 338733829f
commit 780cda6e4b
1 changed files with 3 additions and 1 deletions
--- a/packages/api/src/queue-processor.ts
+++ b/packages/api/src/queue-processor.ts
@ -61,7 +61,9 @@ const main = async () => {
    throw '[queue-processor] error redis is not initialized'
  }

-  const queue = new Queue(QUEUE_NAME)
+  const queue = new Queue(QUEUE_NAME, {
+    connection: workerRedisClient,
+  })

  const worker = new Worker(
    QUEUE_NAME,