diff --git a/apps/server/src/integrations/queue/queue-producers.module.ts b/apps/server/src/integrations/queue/queue-producers.module.ts new file mode 100644 index 000000000..0768fe721 --- /dev/null +++ b/apps/server/src/integrations/queue/queue-producers.module.ts @@ -0,0 +1,11 @@ +import { Global, Module } from '@nestjs/common'; +import { BullModule } from '@nestjs/bullmq'; +import { createQueueRegistrations } from './queue.registrations'; + +// Global so @InjectQueue tokens resolve anywhere, in the app and in worker contexts. +@Global() +@Module({ + imports: [...createQueueRegistrations()], + exports: [BullModule], +}) +export class QueueProducersModule {} diff --git a/apps/server/src/integrations/queue/queue.module.ts b/apps/server/src/integrations/queue/queue.module.ts index 509dbdf47..737f9b74c 100644 --- a/apps/server/src/integrations/queue/queue.module.ts +++ b/apps/server/src/integrations/queue/queue.module.ts @@ -2,10 +2,8 @@ import { Global, Module } from '@nestjs/common'; import { BullModule } from '@nestjs/bullmq'; import { EnvironmentService } from '../environment/environment.service'; import { GeneralQueueProcessor } from './processors/general-queue.processor'; -import { - bullConfigFactory, - createQueueRegistrations, -} from './queue.registrations'; +import { bullConfigFactory } from './queue.registrations'; +import { QueueProducersModule } from './queue-producers.module'; @Global() @Module({ @@ -14,7 +12,7 @@ import { useFactory: bullConfigFactory, inject: [EnvironmentService], }), - ...createQueueRegistrations(), + QueueProducersModule, ], exports: [BullModule], providers: [GeneralQueueProcessor],