lib-task-scheduler
Advanced tools
Comparing version 2.0.82 to 2.0.85
@@ -39,2 +39,4 @@ "use strict"; | ||
this.log.error(`Message Body cannot be parsed as JSON (dropping): ${sqsMessage.Body}`); | ||
// Drop the message. | ||
yield this.sqsClient.deleteMessage(sqsMessage.ReceiptHandle); | ||
} | ||
@@ -45,10 +47,12 @@ else { | ||
} | ||
if (!message.id) { | ||
message.id = sqsMessage.MessageId; | ||
if (message) { | ||
if (!message.id) { | ||
message.id = sqsMessage.MessageId; | ||
} | ||
this.messageMeta[message.id] = { | ||
receiptHandle: sqsMessage.ReceiptHandle, | ||
receiveCount: parseInt(sqsMessage.Attributes['ApproximateReceiveCount']), | ||
}; | ||
return message; | ||
} | ||
this.messageMeta[message.id] = { | ||
receiptHandle: sqsMessage.ReceiptHandle, | ||
receiveCount: parseInt(sqsMessage.Attributes['ApproximateReceiveCount']), | ||
}; | ||
return message; | ||
} | ||
@@ -55,0 +59,0 @@ return null; |
{ | ||
"name": "lib-task-scheduler", | ||
"version": "2.0.82", | ||
"version": "2.0.85", | ||
"description": "A lightweight, modular task scheduler.", | ||
@@ -5,0 +5,0 @@ "homepage": "https://github.com/convoyinc/lib-task-scheduler", |
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
140817
2093