Merge pull request #438 from jonmast/fix-bull-url-config

Update how Redis URL is passed to Bull
bee-queue · Sep 8, 2021 · ddf5048 · ddf5048
2 parents 3d941e3 + 81bf488
commit ddf5048
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/server/queue/index.js b/src/server/queue/index.js
@@ -120,8 +120,14 @@ class Queues {
       if (queueConfig.createClient)
         options.createClient = queueConfig.createClient;
 
+      if (typeof options.redis === 'string') delete options.redis;
+
       const {Bull} = this._config;
-      queue = new Bull(name, options);
+      if (url) {
+        queue = new Bull(name, url, options);
+      } else {
+        queue = new Bull(name, options);
+      }
       queue.IS_BULL = true;
     }