Comparing version 0.0.0-20230913115535 to 0.0.0-20230913120345
@@ -73,4 +73,6 @@ "use strict"; | ||
if (subscription.recovery) { | ||
const currentAttempts = message.properties.headers.rascal?.[subscription.queue ?? '']?.republished ?? | ||
subscription.recovery.attempts; | ||
const currentAttempts = message.properties.headers.rascal?.recovery | ||
? message.properties.headers.rascal?.recovery?.[subscription.queue ?? ''].republished ?? | ||
subscription.recovery.attempts | ||
: 0; | ||
if (currentAttempts === subscription.recovery.attempts) { | ||
@@ -77,0 +79,0 @@ log.error({ err, content }, `${errorMessage} Will nack message and send to dead letter queue`); |
{ | ||
"name": "@axah/mq", | ||
"version": "0.0.0-20230913115535", | ||
"version": "0.0.0-20230913120345", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.js", |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
41305
468