add queue prefix for bull

plezanje-net · Sep 13, 2024 · d572043 · d572043
1 parent 9049f77
commit d572043
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
@@ -40,7 +40,8 @@ import { env } from 'process';
     forwardRef(() => AuditModule), // because audit module is imported in usersmodule and this constitutes a circular dependency (users->audit->activities->users...)
     forwardRef(() => UsersModule),
     BullModule.registerQueue({
-      name: `${env.ENVIRONMENT}-summary`,
+      name: 'summary',
+      prefix: `bull:${env.ENVIRONMENT}`,
     }),
     CragsModule,
   ],

diff --git a/src/app.module.ts b/src/app.module.ts
@@ -134,7 +134,8 @@ import { env } from 'process';
       inject: [ConfigService],
     }),
     BullModule.registerQueue({
-      name: `${env.ENVIRONMENT}-summary`,
+      name: 'summary',
+      prefix: `bull:${env.ENVIRONMENT}`,
     }),
   ],
   providers: [],

diff --git a/src/audit/audit.module.ts b/src/audit/audit.module.ts
@@ -41,7 +41,8 @@ import { env } from 'process';
     ]),
     AuthModule,
     BullModule.registerQueue({
-      name: `${env.ENVIRONMENT}-summary`,
+      name: 'summary',
+      prefix: `bull:${env.ENVIRONMENT}`,
     }),
     forwardRef(() => UsersModule),
     forwardRef(() => CragsModule),

diff --git a/src/crags/crags.module.ts b/src/crags/crags.module.ts
@@ -102,7 +102,8 @@ import { env } from 'process';
     ]),
     forwardRef(() => AuditModule),
     BullModule.registerQueue({
-      name: `${env.ENVIRONMENT}-summary`,
+      name: 'summary',
+      prefix: `bull:${env.ENVIRONMENT}`,
     }),
   ],
   providers: [