feat: added resume method

ladjs · Sep 10, 2019 · 3cc6999 · 3cc6999
1 parent 83d738e
commit 3cc6999
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/index.js b/index.js
@@ -134,6 +134,18 @@ class Bull {
       );
     }
 
+    return this.resume(name);
+  }
+
+  async resume(name) {
+    if (!name) {
+      this.config.logger.info('resuming all job queues');
+      return Promise.all([...this.queues.keys()].map(key => this.resume(key)));
+    }
+
+    const queue = this.queues.get(name);
+    if (!queue) throw new Error(`Queue "${name}" does not exist`);
+    this.config.logger.info(`resuming job queue`, this._getMeta({ queue }));
     return queue.resume();
   }