renamings

Runnable · Sep 29, 2016 · 82e9694 · 82e9694
1 parent fd2b2cd
commit 82e9694
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/rabbitmq.js b/src/rabbitmq.js
@@ -686,7 +686,7 @@ class RabbitMQ {
       timestamp: Date.now(),
       headers: {}
     }
-    jobMeta.headers.previousEvent = RabbitMQ.getKeyFromClsNamespace('currentWorkerName')
+    jobMeta.headers.publisherWorkerName = RabbitMQ.getKeyFromClsNamespace('currentWorkerName')
     return jobMeta
   }
   /**

diff --git a/test/functional/basic.js b/test/functional/basic.js
@@ -57,7 +57,7 @@ describe('Basic Example', () => {
 
   it('should trigger series of events', (done) => {
     testWorkerTwoEmitter.on('task', function (job, jobMeta) {
-      assert.equal(jobMeta.headers.previousEvent, testQueueOne)
+      assert.equal(jobMeta.headers.publisherWorkerName, testQueueOne)
       assert.equal(job.message, 'hello world2')
       done()
     })

diff --git a/test/unit/rabbitmq.js b/test/unit/rabbitmq.js
@@ -773,15 +773,15 @@ describe('rabbitmq', () => {
         ns.run(() => {
           ns.set('currentWorkerName', testEvent)
           const jobMeta = RabbitMQ.buildJobMeta('api')
-          assert.isString(jobMeta.headers.previousEvent, testEvent)
+          assert.isString(jobMeta.headers.publisherWorkerName, testEvent)
           cb()
         })
       })
     })
 
-    it('should not set previousEvent if namespace does not exist', () => {
+    it('should not set publisherWorkerName if namespace does not exist', () => {
       const jobMeta = RabbitMQ.buildJobMeta('api')
-      assert.isUndefined(jobMeta.headers.previousEvent)
+      assert.isUndefined(jobMeta.headers.publisherWorkerName)
     })
   })