notification-processor
Advanced tools
@@ -20,2 +20,5 @@ "use strict"; | ||
}, | ||
Exceptions: { | ||
NonRetryable: require("./exceptions/non.retryable") | ||
}, | ||
Sources: require("./sources"), | ||
@@ -22,0 +25,0 @@ Senders: require("./senders") |
@@ -78,3 +78,6 @@ "use strict"; | ||
return _this2._emitEvent("successful", { context: context, id: id, notification: notification }); | ||
}).catch(NonRetryable, function (error) { | ||
}).catch(function (error) { | ||
if (!(error instanceof NonRetryable)) { | ||
throw error; | ||
} | ||
return _this2._emitEvent("unsuccessful_non_retryable", { context: context, id: id, notification: notification, error: error }); | ||
@@ -81,0 +84,0 @@ }).tapCatch(function (error) { |
@@ -78,3 +78,3 @@ "use strict"; | ||
boundMethodCheck(this, JobProcessor); | ||
return _.pick(err, ["message", "type", "detail.request"]); | ||
return _.pick(err, ["statusCode", "error"]); | ||
} | ||
@@ -81,0 +81,0 @@ }, { |
@@ -35,2 +35,3 @@ "use strict"; | ||
meta: { | ||
messageId: bindingData.messageId, | ||
insertionTime: bindingData.enqueuedTimeUtc, | ||
@@ -37,0 +38,0 @@ dequeueCount: bindingData.deliveryCount, |
{ | ||
"name": "notification-processor", | ||
"version": "4.4.0", | ||
"version": "4.4.1", | ||
"description": "notification-processor", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
100834
56%36
2.86%1397
0.5%