Skip to content

Commit 8c4da74

Browse files
committed
1 parent 5d23fad commit 8c4da74

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

aws/sqs/sqs.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -353,7 +353,7 @@ func (s *SQS) SendNBatch(ctx context.Context, queueURL string, bodies []string)
353353

354354
const (
355355
maxCount = 10
356-
maxSize = 262144 // 256 KiB
356+
maxSize = 1048576 // 1 MiB
357357
)
358358

359359
allErrors := make([]error, 0)

aws/sqs/sqs_integration_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -455,7 +455,7 @@ func TestSendBatch(t *testing.T) {
455455
require.Nil(t, err, fmt.Sprintf("error creating sqs client: %v", err))
456456

457457
// ACTION
458-
var maxBytes int = 262144
458+
var maxBytes int = 1048576
459459
maxSizeSingleMessage := ""
460460
for range maxBytes {
461461
maxSizeSingleMessage += "a"
@@ -474,7 +474,7 @@ func TestSendBatch(t *testing.T) {
474474
assert.NotNil(t, err)
475475

476476
// ACTION
477-
var maxHalfBytes int = 131072
477+
var maxHalfBytes int = 524288
478478
maxHalfSizeMessage := ""
479479
for range maxHalfBytes {
480480
maxHalfSizeMessage += "a"
@@ -531,7 +531,7 @@ func TestSendNBatch(t *testing.T) {
531531
require.Nil(t, err, fmt.Sprintf("error creating sqs client: %v", err))
532532

533533
// ACTION
534-
var maxBytes int = 262144
534+
var maxBytes int = 1048576
535535
maxSizeSingleMessage := ""
536536
for range maxBytes {
537537
maxSizeSingleMessage += "a"

0 commit comments

Comments
 (0)