From 2c9746654d97e354e6407221178d2189e728f8d0 Mon Sep 17 00:00:00 2001
From: Joe Fleming <joe.fleming@gmail.com>
Date: Thu, 28 Apr 2016 15:12:57 -0700
Subject: [PATCH] create debugging output wrapper

---
 src/job.js | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/job.js b/src/job.js
index 0232501..a452919 100644
--- a/src/job.js
+++ b/src/job.js
@@ -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;
     });