Merge pull request #74 from Runnable/assert-on-publish

update error name
Runnable · Aug 18, 2016 · acb2c07 · acb2c07
2 parents e364cc3 + 7d109f2
commit acb2c07
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/rabbitmq.js b/src/rabbitmq.js
@@ -247,7 +247,7 @@ class RabbitMQ {
       const bufferContent = this._validatePublish(queue, content)
       this.log.trace({ queue: queueName, job: content }, 'Publishing job')
       if (!~this.tasks.indexOf(queue)) {
-        throw new Error('Trying to publish task not defined in constructor')
+        throw new Error(`task: "${queue}" not defined in constructor`)
       }
       return Promise.resolve(
         this.publishChannel.sendToQueue(queueName, bufferContent)
@@ -267,7 +267,7 @@ class RabbitMQ {
     return Promise.try(() => {
       const bufferContent = this._validatePublish(exchange, content)
       if (!~this.events.indexOf(exchange)) {
-        throw new Error('Trying to publish event not defined in constructor')
+        throw new Error(`event "${exchange}" not defined in constructor`)
       }
       // events do not need a routing key (so we send '')
       return Promise.resolve(

diff --git a/test/unit/rabbitmq.js b/test/unit/rabbitmq.js
@@ -562,7 +562,7 @@ describe('rabbitmq', () => {
     it('should reject if not defined', () => {
       return assert.isRejected(
         rabbitmq.publishTask('not-real', mockJob),
-        /Trying to publish task not defined in constructor/
+        /task: "not-real" not defined in constructor/
       )
     })
 
@@ -602,8 +602,8 @@ describe('rabbitmq', () => {
 
     it('should reject if not defined', () => {
       return assert.isRejected(
-        rabbitmq.publishEvent('not-real', mockJob),
-        /Trying to publish event not defined in constructor/
+        rabbitmq.publishEvent('unreal', mockJob),
+        /event "unreal" not defined in constructor/
       )
     })