Method _waitForJob

lib/queue.js:499–532

()

  }

  _waitForJob() {
    return helpers
      .callAsync((done) =>
        this.bclient.brpoplpush(
          this.toKey('waiting'),
          this.toKey('active'),
          0,
          done
        )
      )
      .then(
        (jobId) =>
          // Note that the job may be null in the case that the client has
          // removed the job before processing can take place, but after the
          // brpoplpush has returned the job id.
          Job.fromId(this, jobId),
        (err) => {
          if (redis.isAbortError(err) && this.paused) {
            return null;
          }

          this.emit('error', err);

          // Retry the brpoplpush after a delay
          this._redisFailureRetryDelay = this._redisFailureRetryDelay
            ? this._redisFailureRetryDelay * 2
            : this.settings.initialRedisFailureRetryDelay;

          return helpers
            .delay(this._redisFailureRetryDelay)
            .then(() => this._waitForJob());
        }
      );
  }

  _getNextJob() {
    this._redisFailureRetryDelay = 0;