@egodigital/microservices
Advanced tools
Comparing version 0.3.0 to 0.4.1
# Change Log (@egodigital/microservices) | ||
## 0.4.1 | ||
* better error handling of [onMessage](https://egodigital.github.io/node-microservices/classes/nats_listener.natslistener.html#onmessage) listener | ||
## 0.3.0 | ||
@@ -4,0 +8,0 @@ |
@@ -90,5 +90,13 @@ "use strict"; | ||
if (onMessage) { | ||
let message; | ||
try { | ||
message = parseMessage(rawMessage); | ||
} | ||
catch { | ||
rawMessage.ack(); // JSON parse errors should not resend events | ||
return; | ||
} | ||
onMessage({ | ||
ack, | ||
message: parseMessage(rawMessage), | ||
message, | ||
noAck, | ||
@@ -95,0 +103,0 @@ rawMessage |
{ | ||
"name": "@egodigital/microservices", | ||
"version": "0.3.0", | ||
"version": "0.4.1", | ||
"description": "Shared library for microservices, written for Node.js", | ||
@@ -5,0 +5,0 @@ "author": "e.GO Digital GmbH, Aachen, Germany", |
52739
1033