diff --git a/lib/queue.js b/lib/queue.js index 30233c070..2c6ab79c6 100755 --- a/lib/queue.js +++ b/lib/queue.js @@ -1191,7 +1191,7 @@ Queue.prototype.whenCurrentJobsFinished = function() { return this.bclient.connect(); }); - return Promise.all([this.processing[0]]).then(() => { + return Promise.all(this.processing).then(() => { return forcedReconnection; }); };