diff --git a/src/worker.js b/src/worker.js index da5440e..a479d59 100644 --- a/src/worker.js +++ b/src/worker.js @@ -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)); }); } -} \ No newline at end of file +}