fix(queue): expose queue producers through a global module

This commit is contained in:
Philipinho
2026-08-12 21:17:07 +01:00
parent 5d8e9fde8b
commit 809f6eb3be
2 changed files with 14 additions and 5 deletions
@@ -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 {}
@@ -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],