Skip to content

Commit 7ecdb55

Browse files
author
palPalani
committed
Allow more messages to read
1 parent ef08fb1 commit 7ecdb55

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

src/Sqs/Queue.php

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -69,19 +69,17 @@ public function pop($queue = null)
6969
'MaxNumberOfMessages' => 5,
7070
'MessageAttributeNames' => ['All'],
7171
]);
72-
73-
Log::debug('MessageAttributeNames=', [$response]);
74-
72+
7573
if (isset($response['Messages']) && count($response['Messages']) > 0) {
76-
Log::debug('MessageAttributeNames=', [$response['Messages']]);
74+
Log::debug('Messages==', [$response['Messages']]);
7775
$queueId = explode('/', $queue);
7876
$queueId = array_pop($queueId);
7977

8078
$class = (array_key_exists($queueId, $this->container['config']->get('sqs-queue-reader.handlers')))
8179
? $this->container['config']->get('sqs-queue-reader.handlers')[$queueId]
8280
: $this->container['config']->get('sqs-queue-reader.default-handler');
8381

84-
$response = $this->modifyPayload($response['Messages'][0], $class);
82+
$response = $this->modifyPayload($response['Messages'], $class);
8583

8684
if (preg_match('/(5\.[4-8]\..*)|(6\.[0-9]*\..*)|(7\.[0-9]*\..*)|(8\.[0-9]*\..*)/', $this->container->version())) {
8785
return new SqsJob($this->container, $this->sqs, $response, $this->connectionName, $queue);

0 commit comments

Comments
 (0)