diff --git a/src/infrastructure/queue/queue.service.ts b/src/infrastructure/queue/queue.service.ts index b6193e4..cc705a7 100644 --- a/src/infrastructure/queue/queue.service.ts +++ b/src/infrastructure/queue/queue.service.ts @@ -17,10 +17,10 @@ export class QueueService { constructor( private readonly prisma: PrismaService, - @Optional() private readonly eventBus?: any, @InjectQueue(QUEUE_AI_ANALYSIS) private readonly aiQueue: Queue, @InjectQueue(QUEUE_DOCUMENT_IMPORT) private readonly importQueue: Queue, @InjectQueue(QUEUE_NOTIFICATION) private readonly notifyQueue: Queue, + @Optional() private readonly eventBus?: any, ) {} async add(queueName: string, data: any, opts?: { jobId?: string; attempts?: number; backoff?: number }) {