Merge pull request #61 from opsgenie/BIF-810

BIF-810 Change polling strategy from short polling to long polling
opsgenie · Jan 16, 2024 · 48760ae · 48760ae
2 parents 79f203b + 29ebe37
commit 48760ae
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/queue/sqs_provider.go b/queue/sqs_provider.go
@@ -115,7 +115,7 @@ func (qp *sqsProvider) ReceiveMessage(maxNumOfMessage int64, visibilityTimeout i
 		QueueUrl:            &queueUrl,
 		MaxNumberOfMessages: aws.Int64(maxNumOfMessage),
 		VisibilityTimeout:   aws.Int64(visibilityTimeout),
-		WaitTimeSeconds:     aws.Int64(0),
+		WaitTimeSeconds:     aws.Int64(20),
 	}
 
 	qp.refreshClientMu.RLock()

diff --git a/queue/sqs_provider_test.go b/queue/sqs_provider_test.go
@@ -107,7 +107,7 @@ func TestReceiveMessage(t *testing.T) {
 	assert.Equal(t, 2, len(messages))
 	assert.Equal(t, int64(30), *capturedInput.VisibilityTimeout)
 	assert.Equal(t, mockQueueUrl1, *capturedInput.QueueUrl)
-	assert.Equal(t, int64(0), *capturedInput.WaitTimeSeconds) // because of short polling
+	assert.Equal(t, int64(20), *capturedInput.WaitTimeSeconds)
 	assert.Equal(t, int64(10), *capturedInput.MaxNumberOfMessages)
 	assert.Equal(t, 1, len(capturedInput.MessageAttributeNames))
 	assert.Equal(t, "ownerId", *capturedInput.MessageAttributeNames[0])