Merge pull request #177 from plezanje-net/queue-name-hotfix

Add queue prefix
plezanje-net · Sep 15, 2024 · 5b4324c · 5b4324c
2 parents bea16ec + d572043
commit 5b4324c
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 0 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: [
@@ -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
@@ -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
@@ -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
@@ -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: [