Comparing version 1.6.0 to 1.6.1
@@ -418,2 +418,3 @@ 'use strict' | ||
channel.on('error', (err) => { | ||
console.error(err) | ||
self._consume_channel = null | ||
@@ -424,2 +425,3 @@ self.__use_consume_channel() | ||
channel.on('close', () => { | ||
throw new Error('Consumption channel closed') | ||
self._consume_channel = null | ||
@@ -472,2 +474,3 @@ self.__use_consume_channel() | ||
channel.on('error', (err) => { | ||
console.error(err) | ||
self._publish_channel = null | ||
@@ -478,2 +481,3 @@ self.__use_publish_channel() | ||
channel.on('close', () => { | ||
throw new Error('Publish channel closed') | ||
self._publish_channel = null | ||
@@ -634,3 +638,3 @@ self.__use_publish_channel() | ||
caller: message.properties.messageId, | ||
uuid: message.properties.headers.uuid | ||
uuid: message.properties.headers && message.properties.headers.uuid | ||
} | ||
@@ -637,0 +641,0 @@ |
{ | ||
"name": "remit", | ||
"version": "1.6.0", | ||
"version": "1.6.1", | ||
"description": "A small set of functionality used to create microservices that don't need to be aware of one-another's existence.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
46284
7
779