- return DBA::selectToArray('post-delivery', [], ["`inbox-id` = ? AND `failed` < ?", ItemURI::getIdByURI($inbox), 15], ['order' => ['created']]);
+ $rows = DBA::select('post-delivery', [], ["`inbox-id` = ? AND `failed` < ?", ItemURI::getIdByURI($inbox), DI::config()->get('system', 'worker_defer_limit')], ['order' => ['created']]);
+ $deliveries = [];
+ while ($row = DBA::fetch($rows)) {
+ if (!empty($row['receivers'])) {
+ $row['receivers'] = json_decode($row['receivers'], true);
+ } else {
+ $row['receivers'] = [];
+ }
+ $deliveries[] = $row;
+ }
+ DBA::close($rows);
+
+ return $deliveries;