From 82e969476716536a4902ff7d92548c6312bda828 Mon Sep 17 00:00:00 2001 From: Anton Podviaznikov Date: Wed, 28 Sep 2016 17:25:25 -0700 Subject: [PATCH] renamings --- src/rabbitmq.js | 2 +- test/functional/basic.js | 2 +- test/unit/rabbitmq.js | 6 +++--- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/rabbitmq.js b/src/rabbitmq.js index 20c29d9..cb19678 100644 --- 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 index cc577c2..8d0da44 100644 --- 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 index 9ac3002..06e8a1c 100644 --- 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) }) })