diff --git a/src/activities/activities.module.ts b/src/activities/activities.module.ts index ce05fce..4de3553 100644 --- 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 index 4ad91bf..ba06cb9 100644 --- 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 index 7d24095..6ead5f0 100644 --- 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 index 6ed4dba..e342f18 100644 --- 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: [