summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
d9d3120)
Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>
this.checkValidTasksQueueOptions(tasksQueueOptions)
this.opts.tasksQueueOptions =
this.buildTasksQueueOptions(tasksQueueOptions)
this.checkValidTasksQueueOptions(tasksQueueOptions)
this.opts.tasksQueueOptions =
this.buildTasksQueueOptions(tasksQueueOptions)
+ } else if (this.opts.tasksQueueOptions != null) {
delete this.opts.tasksQueueOptions
}
}
delete this.opts.tasksQueueOptions
}
}
this.emitter.emit(PoolEvents.error, error)
}
})
this.emitter.emit(PoolEvents.error, error)
}
})
- if (this.opts.restartWorkerOnError === true) {
- worker.on('error', () => {
+ worker.on('error', () => {
+ if (this.opts.restartWorkerOnError === true) {
this.createAndSetupWorker()
this.createAndSetupWorker()
worker.on('online', this.opts.onlineHandler ?? EMPTY_FUNCTION)
worker.on('exit', this.opts.exitHandler ?? EMPTY_FUNCTION)
worker.once('exit', () => {
worker.on('online', this.opts.onlineHandler ?? EMPTY_FUNCTION)
worker.on('exit', this.opts.exitHandler ?? EMPTY_FUNCTION)
worker.once('exit', () => {