Comparing version 1.7.1 to 1.7.2
@@ -93,2 +93,6 @@ 'use strict' | ||
self._consume_channel.consume(chosen_queue, (message) => { | ||
if (message === null) { | ||
throw new Error('Consumer cancelled') | ||
} | ||
if (!message.properties.timestamp) { | ||
@@ -141,4 +145,2 @@ self.__consume_res(message, callbacks, context) | ||
options.timestamp = Math.ceil(+new Date() / 1000) | ||
self.__connect(() => { | ||
@@ -145,0 +147,0 @@ self.__assert_exchange(() => { |
{ | ||
"name": "remit", | ||
"version": "1.7.1", | ||
"version": "1.7.2", | ||
"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", |
45835
774