We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e43dedc commit 1347f3dCopy full SHA for 1347f3d
src/Sqs/Queue.php
@@ -86,6 +86,7 @@ public function pop($queue = null)
86
? $this->container['config']->get('sqs-queue-reader.handlers')[$queueId]['class']
87
: $this->container['config']->get('sqs-queue-reader.default-handler')['class'];
88
89
+ Log::debug('Count, class==', [$count, $class]);
90
if ($count === 1) {
91
$response = $this->modifySinglePayload($response['Messages'][0], $class);
92
} else {
@@ -116,6 +117,7 @@ private function modifySinglePayload($payload, $class)
116
117
$body = json_decode($payload['Body'], true);
118
119
$body = [
120
+ 'uuid' => (string) Str::uuid(),
121
'job' => $class . '@handle',
122
'data' => isset($body['data']) ? $body['data'] : $body,
123
];
0 commit comments