Skip to content

Commit dbece1a

Browse files
author
palPalani
committed
Fix getting mmultiple message
1 parent 20ee336 commit dbece1a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/Sqs/Queue.php

+2-2
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ public function pop($queue = null)
8080
: $this->container['config']->get('sqs-queue-reader.default-handler');
8181

8282
$response = $this->modifyPayload($response['Messages'], $class);
83-
83+
Log::debug('New $response==', [$response]);
8484
if (preg_match('/(5\.[4-8]\..*)|(6\.[0-9]*\..*)|(7\.[0-9]*\..*)|(8\.[0-9]*\..*)/', $this->container->version())) {
8585
return new SqsJob($this->container, $this->sqs, $response, $this->connectionName, $queue);
8686
}
@@ -113,7 +113,7 @@ private function modifyPayload($payload, $class)
113113

114114
$body = [];
115115
foreach ($payload as $item) {
116-
Log::debug('Each Messages==', [$item]);
116+
//Log::debug('Each Messages==', [$item]);
117117
$body[] = json_decode($item['Body'], true);
118118
}
119119

0 commit comments

Comments
 (0)