sqs-producer
Advanced tools
Comparing version 3.0.0-alpha.1 to 3.0.0-alpha.2
@@ -52,4 +52,4 @@ "use strict"; | ||
const result = await this.sqs.send(command); | ||
const failedMessagesBatch = failedMessages.concat(result.Failed.map((entry) => entry.Id)); | ||
const successfulMessagesBatch = successfulMessages.concat(result.Successful); | ||
const failedMessagesBatch = failedMessages.concat((result === null || result === void 0 ? void 0 : result.Failed.map((entry) => entry.Id)) || []); | ||
const successfulMessagesBatch = successfulMessages.concat((result === null || result === void 0 ? void 0 : result.Successful) || []); | ||
if (endIndex < messages.length) { | ||
@@ -56,0 +56,0 @@ return this.sendBatch(failedMessagesBatch, successfulMessagesBatch, messages, endIndex); |
{ | ||
"name": "sqs-producer", | ||
"version": "3.0.0-alpha.1", | ||
"version": "3.0.0-alpha.2", | ||
"description": "Enqueues messages onto a given SQS queue", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
@@ -94,6 +94,6 @@ import { | ||
const failedMessagesBatch = failedMessages.concat( | ||
result.Failed.map((entry) => entry.Id) | ||
result?.Failed.map((entry) => entry.Id) || [] | ||
); | ||
const successfulMessagesBatch = successfulMessages.concat( | ||
result.Successful | ||
result?.Successful || [] | ||
); | ||
@@ -100,0 +100,0 @@ |
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
21512
19