Method constructor

src/job-queue/redis-adapter.ts:10–19

(redisUrl: string, queueName: string, options?: QueueOptions)

  private redisSubscriber: IORedis

  constructor(redisUrl: string, queueName: string, options?: QueueOptions) {
    super(queueName, options)

    this.redisBlocking = new IORedis(redisUrl)
    this.redisNonBlocking = new IORedis(redisUrl)
    this.redisSubscriber = new IORedis(redisUrl)

    this.listenForExpiredJobs()
    this.checkForExpiredJobs()
  }

  get length() {
    return this.redisNonBlocking.zcard(this.activeJobsQueue)