Skip to content

Commit 06a8538

Browse files
Merge pull request #3 from atlassian/BIF-810-JEC-Latency
BIF-810: Short polling is changed to long polling
2 parents f722007 + 8effe17 commit 06a8538

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

queue/sqs_provider.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ func (qp *sqsProvider) ReceiveMessage(maxNumOfMessage int64, visibilityTimeout i
117117
QueueUrl: &queueUrl,
118118
MaxNumberOfMessages: aws.Int64(maxNumOfMessage),
119119
VisibilityTimeout: aws.Int64(visibilityTimeout),
120-
WaitTimeSeconds: aws.Int64(0),
120+
WaitTimeSeconds: aws.Int64(20),
121121
}
122122

123123
qp.refreshClientMu.RLock()

queue/sqs_provider_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ func TestReceiveMessage(t *testing.T) {
107107
assert.Equal(t, 2, len(messages))
108108
assert.Equal(t, int64(30), *capturedInput.VisibilityTimeout)
109109
assert.Equal(t, mockQueueUrl1, *capturedInput.QueueUrl)
110-
assert.Equal(t, int64(0), *capturedInput.WaitTimeSeconds) // because of short polling
110+
assert.Equal(t, int64(20), *capturedInput.WaitTimeSeconds)
111111
assert.Equal(t, int64(10), *capturedInput.MaxNumberOfMessages)
112112
assert.Equal(t, 2, len(capturedInput.MessageAttributeNames))
113113
assert.Equal(t, "ownerId", *capturedInput.MessageAttributeNames[0])

0 commit comments

Comments
 (0)