diff --git a/lib/queue.js b/lib/queue.js
index 73cd8bf..b60ec23 100755
--- 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
index c7c3b0c..a656a40 100644
--- 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
index ee50c01..aa454fd 100644
--- 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);
   });
 });