diff --git a/src/classes/queue-scheduler.ts b/src/classes/queue-scheduler.ts
index 562ec2cb25..7511d92379 100644
--- 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
index 7c8bf70dc3..7bacaee6b3 100644
--- 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
index c0b1367d9c..c92fee2fdf 100644
--- 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...
           }
         },