From 5954ee1d511bd3d9ddcc26f25ed44acc0602d860 Mon Sep 17 00:00:00 2001
From: Joe Fleming <joe.fleming@gmail.com>
Date: Mon, 6 Jun 2016 16:59:02 -0700
Subject: [PATCH] append option headers to the index request

---
 src/job.js | 38 +++++++++++++++++++++-----------------
 1 file changed, 21 insertions(+), 17 deletions(-)

diff --git a/src/job.js b/src/job.js
index 04ad422..7e8ee0f 100644
--- a/src/job.js
+++ b/src/job.js
@@ -28,25 +28,29 @@ export default class Job extends events.EventEmitter {
 
     this.debug = (...msg) => debug(...msg, `id: ${this.id}`);
 
+    const indexParams = {
+      index: this.index,
+      type: this.doctype,
+      id: this.id,
+      body: {
+        jobtype: this.jobtype,
+        payload: this.payload,
+        priority: this.priority,
+        created_by: this.created_by,
+        timeout: this.timeout,
+        process_expiration: new Date(0), // use epoch so the job query works
+        created_at: new Date(),
+        attempts: 0,
+        max_attempts: this.maxAttempts,
+        status: contstants.JOB_STATUS_PENDING,
+      }
+    };
+
+    if (options.headers) indexParams.headers = options.headers;
+
     this.ready = createIndex(this.client, this.index, this.doctype)
     .then(() => {
-      return this.client.index({
-        index: this.index,
-        type: this.doctype,
-        id: this.id,
-        body: {
-          jobtype: this.jobtype,
-          payload: this.payload,
-          priority: this.priority,
-          created_by: this.created_by,
-          timeout: this.timeout,
-          process_expiration: new Date(0), // use epoch so the job query works
-          created_at: new Date(),
-          attempts: 0,
-          max_attempts: this.maxAttempts,
-          status: contstants.JOB_STATUS_PENDING,
-        }
-      })
+      return this.client.index(indexParams)
       .then((doc) => {
         this.document = {
           id: doc._id,