fix(queue): return correct workers with getWorkers()

OptimalBits · Feb 14, 2022 · 193644c · 193644c
1 parent d11a9ff
commit 193644c
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/lib/queue.js b/lib/queue.js
@@ -284,7 +284,6 @@ function redisClientGetter(queue, options, initCallback) {
         return connections[type];
       }
       const clientOptions = _.assign({}, options.redis);
-      clientOptions.connectionName = this.clientName();
 
       const client = (connections[type] = createClient(type, clientOptions));
 

diff --git a/lib/worker.js b/lib/worker.js
@@ -13,7 +13,7 @@ module.exports = function(Queue) {
     return utils
       .isRedisReady(this.client)
       .then(() => {
-        return this.client.client('setname', this.clientName());
+        return this.bclient.client('setname', this.clientName());
       })
       .catch(err => {
         if (!clientCommandMessageReg.test(err.message)) throw err;

diff --git a/test/test_worker.js b/test/test_worker.js
@@ -27,11 +27,12 @@ describe('workers', () => {
     });
   });
 
-  it('should get all workers for this queue', () => {
+  it('should get all workers for this queue', async () => {
     queue.process(() => {});
 
-    return queue.getWorkers().then(workers => {
-      expect(workers).to.have.length(1);
-    });
+    await queue.bclient.ping();
+
+    const workers = await queue.getWorkers();
+    expect(workers).to.have.length(1);
   });
 });