fix: support redis configuration with bullmq (#294)

bee-queue · Nov 26, 2020 · ab4b806 · ab4b806
1 parent 951ba92
commit ab4b806
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/server/queue/index.js b/src/server/queue/index.js
@@ -98,7 +98,11 @@ class Queues {
       if (queueConfig.createClient) options.createClient = queueConfig.createClient;
 
       const { BullMQ } = this._config;
-      queue = new BullMQ(name, options);
+      const { redis, ...rest } = options;
+      queue = new BullMQ(name, {
+        connection: redis,
+        ...rest,
+      });
       queue.IS_BULLMQ = true;
     } else {
       if (queueConfig.createClient) options.createClient = queueConfig.createClient;