add environment to queue name

plezanje-net · Sep 13, 2024 · 9049f77 · 9049f77
1 parent bea16ec
commit 9049f77
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git 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: [
@@ -39,7 +40,7 @@ import { CragsModule } from '../crags/crags.module';
     forwardRef(() => AuditModule), // because audit module is imported in usersmodule and this constitutes a circular dependency (users->audit->activities->users...)
     forwardRef(() => UsersModule),
     BullModule.registerQueue({
-      name: 'summary',
+      name: `${env.ENVIRONMENT}-summary`,
     }),
     CragsModule,
   ],

diff --git 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: [
@@ -133,7 +134,7 @@ import { Parking } from './crags/entities/parking.entity';
       inject: [ConfigService],
     }),
     BullModule.registerQueue({
-      name: 'summary',
+      name: `${env.ENVIRONMENT}-summary`,
     }),
   ],
   providers: [],

diff --git 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: [
@@ -40,7 +41,7 @@ import { CragsModule } from '../crags/crags.module';
     ]),
     AuthModule,
     BullModule.registerQueue({
-      name: 'summary',
+      name: `${env.ENVIRONMENT}-summary`,
     }),
     forwardRef(() => UsersModule),
     forwardRef(() => CragsModule),

diff --git 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: [
@@ -101,7 +102,7 @@ import { AreaLoader } from './loaders/area.loader';
     ]),
     forwardRef(() => AuditModule),
     BullModule.registerQueue({
-      name: 'summary',
+      name: `${env.ENVIRONMENT}-summary`,
     }),
   ],
   providers: [