We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dbece1a commit 8e18d2bCopy full SHA for 8e18d2b
src/Sqs/Queue.php
@@ -115,16 +115,18 @@ private function modifyPayload($payload, $class)
115
foreach ($payload as $item) {
116
//Log::debug('Each Messages==', [$item]);
117
$body[] = json_decode($item['Body'], true);
118
+ $attributes = $item['Attributes'];
119
}
120
121
$body = [
122
'job' => $class . '@handle',
123
'data' => $body,
124
];
125
- $payload['Body'] = json_encode($body);
126
+ $newPayload['Body'] = json_encode($body);
127
+ $newPayload['Attributes'] = $attributes;
128
- return $payload;
129
+ return $newPayload;
130
131
132
/**
0 commit comments