We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5b1640b commit eeabfefCopy full SHA for eeabfef
src/SqsQueueReaderServiceProvider.php
@@ -35,11 +35,11 @@ public function boot(): void
35
$data = $event->job->payload();
36
Log::debug('Job payload==', [$data]);
37
38
- $batchIds = array_column($data, 'batchIds');
+ $batchIds = array_column($data['data'], 'batchIds');
39
Log::debug('Job array_column==', [$batchIds]);
40
$batchIds = array_chunk($batchIds, 10);
41
Log::debug('Job array_chunk==', [$batchIds]);
42
-
+
43
foreach ($batchIds as $batch) {
44
//Deletes up to ten messages from the specified queue.
45
$result = $event->job->deleteMessageBatch([
0 commit comments