w33ble/elastiq
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

pass the entire queue to the Job instance

Browse Source
This commit is contained in:
Joe Fleming
2016-07-11 11:28:40 -07:00
parent a50dbf752e
commit 40d67829c8
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/index.js
View File

@@ -49,7 +49,7 @@ export default class Esqueue extends events.EventEmitter {
indexSettings: this.settings.indexSettings, indexSettings: this.settings.indexSettings,
}); });
return new Job(this.client, index, type, payload, options); return new Job(this, index, type, payload, options);
} }
registerWorker(type, workerFn, opts) { registerWorker(type, workerFn, opts) {

5
src/job.js
View File

@@ -9,13 +9,14 @@ const debug = logger('esqueue:job');
const puid = new Puid(); const puid = new Puid();
export default class Job extends events.EventEmitter { export default class Job extends events.EventEmitter {
constructor(client, index, type, payload, options = {}) { constructor(queue, index, type, payload, options = {}) {
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 (!isPlainObject(payload)) throw new Error('Payload must be a plain object'); if (!isPlainObject(payload)) throw new Error('Payload must be a plain object');
super(); super();
this.client = options.client || client; this.queue = queue;
this.client = options.client || this.queue.client;
this.id = puid.generate(); this.id = puid.generate();
this.index = index; this.index = index;
this.jobtype = type; this.jobtype = type;