From ef128c4452fedcaa0e432ff0bcb7078e94d1c8e8 Mon Sep 17 00:00:00 2001 From: Brandon Wagner Date: Thu, 7 Oct 2021 20:48:32 -0500 Subject: [PATCH 1/3] up sqs max messages and lower wait time and visibility timeout on messages --- pkg/monitor/sqsevent/sqs-monitor.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/monitor/sqsevent/sqs-monitor.go b/pkg/monitor/sqsevent/sqs-monitor.go index 7bd33a72..3c4f1205 100644 --- a/pkg/monitor/sqsevent/sqs-monitor.go +++ b/pkg/monitor/sqsevent/sqs-monitor.go @@ -154,9 +154,9 @@ func (m SQSMonitor) receiveQueueMessages(qURL string) ([]*sqs.Message, error) { aws.String(sqs.QueueAttributeNameAll), }, QueueUrl: &qURL, - MaxNumberOfMessages: aws.Int64(5), - VisibilityTimeout: aws.Int64(20), // 20 seconds - WaitTimeSeconds: aws.Int64(20), // Max long polling + MaxNumberOfMessages: aws.Int64(10), + VisibilityTimeout: aws.Int64(10), // 10 seconds + WaitTimeSeconds: aws.Int64(10), // Max long polling }) if err != nil { From ec95fdba999de1ff2641c009f4f3451cccd877d4 Mon Sep 17 00:00:00 2001 From: Brandon Wagner Date: Thu, 7 Oct 2021 20:51:54 -0500 Subject: [PATCH 2/3] waittime back to 20 sec --- pkg/monitor/sqsevent/sqs-monitor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/monitor/sqsevent/sqs-monitor.go b/pkg/monitor/sqsevent/sqs-monitor.go index 3c4f1205..93244a9c 100644 --- a/pkg/monitor/sqsevent/sqs-monitor.go +++ b/pkg/monitor/sqsevent/sqs-monitor.go @@ -156,7 +156,7 @@ func (m SQSMonitor) receiveQueueMessages(qURL string) ([]*sqs.Message, error) { QueueUrl: &qURL, MaxNumberOfMessages: aws.Int64(10), VisibilityTimeout: aws.Int64(10), // 10 seconds - WaitTimeSeconds: aws.Int64(10), // Max long polling + WaitTimeSeconds: aws.Int64(20), // Max long polling }) if err != nil { From 263d306f4af11584bd3fd835306820d1a211ed05 Mon Sep 17 00:00:00 2001 From: Brandon Wagner Date: Thu, 7 Oct 2021 20:59:31 -0500 Subject: [PATCH 3/3] revert visibility timeout --- pkg/monitor/sqsevent/sqs-monitor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/monitor/sqsevent/sqs-monitor.go b/pkg/monitor/sqsevent/sqs-monitor.go index 93244a9c..ac00ec14 100644 --- a/pkg/monitor/sqsevent/sqs-monitor.go +++ b/pkg/monitor/sqsevent/sqs-monitor.go @@ -155,7 +155,7 @@ func (m SQSMonitor) receiveQueueMessages(qURL string) ([]*sqs.Message, error) { }, QueueUrl: &qURL, MaxNumberOfMessages: aws.Int64(10), - VisibilityTimeout: aws.Int64(10), // 10 seconds + VisibilityTimeout: aws.Int64(20), // 20 seconds WaitTimeSeconds: aws.Int64(20), // Max long polling })