diff --git a/src/queueAdapters/bullMQ.ts b/src/queueAdapters/bullMQ.ts index 169fd1c0..94d375ad 100644 --- a/src/queueAdapters/bullMQ.ts +++ b/src/queueAdapters/bullMQ.ts @@ -22,7 +22,7 @@ export class BullMQAdapter extends BaseAdapter { } public getName(): string { - return this.queue.toKey('~') + return this.queue.name } public clean(jobStatus: JobCleanStatus, graceTimeMs: number): Promise {