diff --git a/src/activities/activities.module.ts b/src/activities/activities.module.ts index 3636606..4de3553 100644 --- a/src/activities/activities.module.ts +++ b/src/activities/activities.module.ts @@ -20,6 +20,7 @@ import { Sector } from '../crags/entities/sector.entity'; import { Country } from '../crags/entities/country.entity'; import { BullModule } from '@nestjs/bull'; import { CragsModule } from '../crags/crags.module'; +import { env } from 'process'; @Module({ imports: [ @@ -40,6 +41,7 @@ import { CragsModule } from '../crags/crags.module'; forwardRef(() => UsersModule), BullModule.registerQueue({ name: 'summary', + prefix: `bull:${env.ENVIRONMENT}`, }), CragsModule, ], diff --git a/src/app.module.ts b/src/app.module.ts index 8fc5c3f..ba06cb9 100644 --- a/src/app.module.ts +++ b/src/app.module.ts @@ -44,6 +44,7 @@ import EntityCacheSubscriber from './core/utils/entity-cache/entity-cache.subscr import { SnakeNamingStrategy } from 'typeorm-naming-strategies'; import { BullModule } from '@nestjs/bull'; import { Parking } from './crags/entities/parking.entity'; +import { env } from 'process'; @Module({ imports: [ @@ -134,6 +135,7 @@ import { Parking } from './crags/entities/parking.entity'; }), BullModule.registerQueue({ name: 'summary', + prefix: `bull:${env.ENVIRONMENT}`, }), ], providers: [], diff --git a/src/audit/audit.module.ts b/src/audit/audit.module.ts index badca3a..6ead5f0 100644 --- a/src/audit/audit.module.ts +++ b/src/audit/audit.module.ts @@ -21,6 +21,7 @@ import { ActivityRoute } from '../activities/entities/activity-route.entity'; import { BullModule } from '@nestjs/bull'; import { UsersModule } from '../users/users.module'; import { CragsModule } from '../crags/crags.module'; +import { env } from 'process'; @Module({ imports: [ @@ -41,6 +42,7 @@ import { CragsModule } from '../crags/crags.module'; AuthModule, BullModule.registerQueue({ name: 'summary', + prefix: `bull:${env.ENVIRONMENT}`, }), forwardRef(() => UsersModule), forwardRef(() => CragsModule), diff --git a/src/crags/crags.module.ts b/src/crags/crags.module.ts index 1bcb273..e342f18 100644 --- a/src/crags/crags.module.ts +++ b/src/crags/crags.module.ts @@ -71,6 +71,7 @@ import { RouteEvent } from './entities/route-event.entity'; import { Parking } from './entities/parking.entity'; import { ParkingsService } from './services/parkings.service'; import { AreaLoader } from './loaders/area.loader'; +import { env } from 'process'; @Module({ imports: [ @@ -102,6 +103,7 @@ import { AreaLoader } from './loaders/area.loader'; forwardRef(() => AuditModule), BullModule.registerQueue({ name: 'summary', + prefix: `bull:${env.ENVIRONMENT}`, }), ], providers: [