Comparing version 1.1.5 to 1.1.6
@@ -432,4 +432,5 @@ 'use strict' | ||
try { | ||
callback(data) | ||
self._channel.ack(message) | ||
callback.call(context, data, function (err) { | ||
self._channel.ack(message) | ||
}) | ||
} catch (e) { | ||
@@ -436,0 +437,0 @@ if (message.properties.headers && message.properties.headers.attempts && message.properties.headers.attempts > 4) { |
{ | ||
"name": "remit", | ||
"version": "1.1.5", | ||
"version": "1.1.6", | ||
"description": "A small set of tools used to create simple microservices that don't need to be aware of one-another's existence.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
20618
318