fix: use emit instead of console.error

taskforcesh · Jan 15, 2020 · d5df6f5 · d5df6f5
1 parent 05750db
commit d5df6f5
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 10 deletions.
diff --git a/src/classes/queue-scheduler.ts b/src/classes/queue-scheduler.ts
@@ -29,9 +29,7 @@ export class QueueScheduler extends QueueBase {
   constructor(protected name: string, opts: QueueSchedulerOptions = {}) {
     super(name, { maxStalledCount: 1, stalledInterval: 30000, ...opts });
 
-    this.run().catch(error => {
-      console.error(error);
-    });
+    this.run().catch(this.emit.bind(this));
   }
 
   private async run() {

diff --git a/src/classes/queue.ts b/src/classes/queue.ts
@@ -29,9 +29,7 @@ export class Queue<T = any> extends QueueGetters {
           get(opts, 'streams.events.maxLen', 10000),
         ),
       )
-      .catch(error => {
-        console.error(error);
-      });
+      .catch(this.emit.bind(this));
   }
 
   get defaultJobOptions() {

diff --git a/src/classes/worker.ts b/src/classes/worker.ts
@@ -81,9 +81,7 @@ export class Worker<T = any> extends QueueBase {
     }
     this.timerManager = new TimerManager();
 
-    this.run().catch(error => {
-      console.error(error);
-    });
+    this.run().catch(this.emit.bind(this));
   }
 
   get repeat() {
@@ -256,7 +254,7 @@ export class Worker<T = any> extends QueueBase {
               // FIXME if result = 0 (missing lock), reject processFn promise to take next job?
             }
           } catch (error) {
-            console.error('Error extending lock ', error);
+            this.emit.bind(this)(error);
             // Somehow tell the worker this job should stop processing...
           }
         },