Skip to content

Commit 615cdbc

Browse files
author
palPalani
committed
Fix getting mmultiple message
1 parent 7ecdb55 commit 615cdbc

File tree

1 file changed

+15
-1
lines changed

1 file changed

+15
-1
lines changed

src/Sqs/Queue.php

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ public function pop($queue = null)
6969
'MaxNumberOfMessages' => 5,
7070
'MessageAttributeNames' => ['All'],
7171
]);
72-
72+
7373
if (isset($response['Messages']) && count($response['Messages']) > 0) {
7474
Log::debug('Messages==', [$response['Messages']]);
7575
$queueId = explode('/', $queue);
@@ -100,13 +100,27 @@ private function modifyPayload($payload, $class)
100100
$payload = json_decode($payload, true);
101101
}
102102

103+
/*
103104
$body = json_decode($payload['Body'], true);
104105
105106
$body = [
106107
'job' => $class . '@handle',
107108
'data' => isset($body['data']) ? $body['data'] : $body,
108109
];
109110
111+
$payload['Body'] = json_encode($body);
112+
*/
113+
114+
$body = [];
115+
foreach ($payload as $item) {
116+
$body[] = json_decode($item['Body'], true);
117+
}
118+
119+
$body = [
120+
'job' => $class . '@handle',
121+
'data' => $body,
122+
];
123+
110124
$payload['Body'] = json_encode($body);
111125

112126
return $payload;

0 commit comments

Comments
 (0)