feat(bullmq): prevent name collisions on different queues

tsedio · Oct 16, 2023 · 1ef9754 · 1ef9754
1 parent 4fb6c71
commit 1ef9754
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/packages/third-parties/bullmq/src/decorators/Job.ts b/packages/third-parties/bullmq/src/decorators/Job.ts
@@ -10,7 +10,7 @@ export function Job(name: string, queue: string = "default", opts: JobsOptions =
       opts
     }),
     Injectable({
-      provide: `bullmq.job.${name}`,
+      provide: `bullmq.job.${queue}.${name}`,
       type: opts.repeat ? "bullmq:cron" : "bullmq:job"
     })
   );