Merge pull request #10 from jasonallen/patch-1
Fix typo in Worker Class name
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 = {}) {
|
constructor(queue, type, workerFn, opts = {}) {
|
||||||
if (typeof type !== 'string') throw new Error('Type must be a string');
|
if (typeof type !== 'string') throw new Error('Type must be a string');
|
||||||
if (typeof workerFn !== 'function') throw new Error('Worker must be a function');
|
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));
|
this.emit(constants.EVENT_WORKER_JOB_SEARCH_ERROR, this._formatErrorParams(err));
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user