fix: add check in each one of bull queue adapters

felixmosh · Oct 29, 2024 · d0e42c7 · d0e42c7
1 parent ff52103
commit d0e42c7
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/packages/api/src/queueAdapters/bull.ts b/packages/api/src/queueAdapters/bull.ts
@@ -1,4 +1,5 @@
 import { Job, Queue } from 'bull';
+import BullQueue from 'bull';
 import {
   JobCleanStatus,
   JobCounts,
@@ -13,6 +14,10 @@ import { BaseAdapter } from './base';
 export class BullAdapter extends BaseAdapter {
   constructor(public queue: Queue, options: Partial<QueueAdapterOptions> = {}) {
     super('bull', { ...options, allowCompletedRetries: false });
+
+    if (!(queue instanceof BullQueue)) {
+      throw new Error(`You've used the Bull adapter with a non-Bull queue.`);
+    }
   }
 
   public getRedisInfo(): Promise<string> {

diff --git a/packages/api/src/queueAdapters/bullMQ.ts b/packages/api/src/queueAdapters/bullMQ.ts
@@ -13,6 +13,9 @@ import { BaseAdapter } from './base';
 export class BullMQAdapter extends BaseAdapter {
   constructor(private queue: Queue, options: Partial<QueueAdapterOptions> = {}) {
     super('bullmq', options);
+    if (!(queue instanceof Queue)) {
+      throw new Error(`You've used the BullMQ adapter with a non-BullMQ queue.`);
+    }
   }
 
   public async getRedisInfo(): Promise<string> {