Method getEventPromise

lib/queue.js:97–119

()

        if (this._isReady) return resolve(this._isReady);

        const getEventPromise = () => {
          if (this.settings.getEvents || this.settings.activateDelayedJobs) {
            return this.makeClient('eclient', true).then(() => {
              this.eclient.on('message', this._onMessage.bind(this));
              const channels = [];
              if (this.settings.getEvents) {
                channels.push(this.toKey('events'));
              }
              if (this.settings.activateDelayedJobs) {
                channels.push(this.toKey('earlierDelayed'));
              }
              return Promise.all(
                channels.map((channel) =>
                  helpers.callAsync((done) =>
                    this.eclient.subscribe(channel, done)
                  )
                )
              );
            });
          }

          return null;
        };

        const eventsPromise = getEventPromise();
        // Wait for Lua scripts and client connections to load. Also wait for