create debugging output wrapper

This commit is contained in:
2016-04-28 15:12:57 -07:00
parent 6ea711da87
commit 2c9746654d

View File

@@ -24,6 +24,8 @@ export default class Job extends events.EventEmitter {
this.maxAttempts = options.max_attempts || 3;
this.priority = Math.max(Math.min(options.priority || 10, 20), -20);
this.debug = (...msg) => debug(...msg, `id: ${this.id}`);
this.ready = createIndex(client, index)
.then(() => {
return this.client.index({
@@ -46,11 +48,12 @@ export default class Job extends events.EventEmitter {
type: doc._type,
version: doc._version,
};
debug('Job created', this.document);
this.debug('Job created');
this.emit('created', this.document);
});
})
.catch((err) => {
debug('Job creation failed', err);
this.debug('Job creation failed', err);
this.emit('error', err);
throw err;
});