Fix typo in Worker Class name
It was mistakenly called Job.
This commit is contained in:
@@ -16,7 +16,7 @@ function formatJobObject(job) {
|
||||
};
|
||||
}
|
||||
|
||||
export default class Job extends events.EventEmitter {
|
||||
export default class Worker extends events.EventEmitter {
|
||||
constructor(queue, type, workerFn, opts = {}) {
|
||||
if (typeof type !== 'string') throw new Error('Type must be a string');
|
||||
if (typeof workerFn !== 'function') throw new Error('Worker must be a function');
|
||||
@@ -335,4 +335,4 @@ export default class Job extends events.EventEmitter {
|
||||
this.emit(constants.EVENT_WORKER_JOB_SEARCH_ERROR, this._formatErrorParams(err));
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user