Merge pull request #22239 from lshwayne96/fix/events-aws-sqs

Events backend module AWS SQS - Fix errors when deleting SQS messages
This commit is contained in:
Fredrik Adelöw
2024-01-15 09:13:41 +01:00
committed by GitHub
2 changed files with 10 additions and 2 deletions
+8
View File
@@ -0,0 +1,8 @@
---
'@backstage/plugin-events-backend-module-aws-sqs': patch
---
Fix errors when deleting SQS messages:
- If zero messages were received, skip deletion to avoid `EmptyBatchRequest` error from the SQS client.
- If zero failures were returned from the SQS client during deletion, skip error logging.
@@ -111,7 +111,7 @@ export class AwsSqsConsumingEventPublisher implements EventPublisher {
}
private async deleteMessages(messages?: Message[]): Promise<void> {
if (!messages) {
if (!messages || messages.length === 0) {
return;
}
@@ -129,7 +129,7 @@ export class AwsSqsConsumingEventPublisher implements EventPublisher {
const result = await this.sqs.send(
new DeleteMessageBatchCommand(deleteParams),
);
if (result.Failed) {
if (result.Failed && result.Failed.length > 0) {
this.logger.error(
`Failed to delete ${result.Failed!.length} of ${
messages.length