Fix errors when deleting SQS messages

Signed-off-by: lshwayne96 <lshwayne96@gmail.com>
This commit is contained in:
lshwayne96
2024-01-15 12:37:57 +08:00
parent 56d3373c82
commit 7b8e551a83
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