- private buildQueueScheduler (handlerName: JobType, produceOnly: boolean) {
- const queueSchedulerOptions: QueueSchedulerOptions = {
- autorun: !produceOnly,
- connection: this.getRedisConnection(),
- prefix: this.jobRedisPrefix,
- maxStalledCount: 10
- }
-
- const queueScheduler = new QueueScheduler(handlerName, queueSchedulerOptions)
- queueScheduler.on('error', err => { logger.error('Error in job queue scheduler %s.', handlerName, { err }) })
-
- this.queueSchedulers[handlerName] = queueScheduler
- }
-
- private buildQueueEvent (handlerName: JobType, produceOnly: boolean) {