sqs-producer
Advanced tools
Comparing version 3.0.0-alpha.2 to 3.0.0-alpha.3
@@ -44,2 +44,3 @@ "use strict"; | ||
async sendBatch(failedMessages, successfulMessages, messages, startIndex) { | ||
var _a; | ||
const endIndex = startIndex + this.batchSize; | ||
@@ -53,3 +54,3 @@ const batch = messages.slice(startIndex, endIndex); | ||
const result = await this.sqs.send(command); | ||
const failedMessagesBatch = failedMessages.concat((result === null || result === void 0 ? void 0 : result.Failed.map((entry) => entry.Id)) || []); | ||
const failedMessagesBatch = failedMessages.concat(((_a = result === null || result === void 0 ? void 0 : result.Failed) === null || _a === void 0 ? void 0 : _a.map((entry) => entry.Id)) || []); | ||
const successfulMessagesBatch = successfulMessages.concat((result === null || result === void 0 ? void 0 : result.Successful) || []); | ||
@@ -56,0 +57,0 @@ if (endIndex < messages.length) { |
{ | ||
"name": "sqs-producer", | ||
"version": "3.0.0-alpha.2", | ||
"version": "3.0.0-alpha.3", | ||
"description": "Enqueues messages onto a given SQS queue", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
@@ -94,3 +94,3 @@ import { | ||
const failedMessagesBatch = failedMessages.concat( | ||
result?.Failed.map((entry) => entry.Id) || [] | ||
result?.Failed?.map((entry) => entry.Id) || [] | ||
); | ||
@@ -97,0 +97,0 @@ const successfulMessagesBatch = successfulMessages.concat( |
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
21576
421