Method init

backend/src/queues/monkey-queue.ts:22–35

(redisConnection?: IORedis.Redis)

  }

  init(redisConnection?: IORedis.Redis): void {
    if (this.jobQueue !== undefined || !redisConnection) {
      return;
    }

    this.jobQueue = new Queue(this.queueName, {
      ...this.queueOpts,
      connection: redisConnection as ConnectionOptions,
    });

    this._queueScheduler = new QueueScheduler(this.queueName, {
      connection: redisConnection as ConnectionOptions,
    });
  }

  async add(taskName: string, task: T, jobOpts?: JobsOptions): Promise<void> {
    if (this.jobQueue === undefined) {