This commit is contained in:
rykuno 2024-08-07 10:19:26 -05:00
parent ebc752233c
commit 0dc94ad1cb

View file

@ -2,10 +2,9 @@ import { inject, injectable } from "tsyringe";
import { Queue, Worker, type Processor } from 'bullmq';
import { RedisProvider } from "../providers/redis.provider";
@injectable()
export class JobsService {
constructor(@inject(RedisProvider) private readonly redis: RedisProvider, name: string) { }
constructor(@inject(RedisProvider) private readonly redis: RedisProvider) { }
createQueue(name: string) {
return new Queue(name, { connection: this.redis })