- $contacts = DBA::select('contact', ['id', 'url', 'network'], $condition);
- $r = DBA::toArray($contacts);
- }
-
- // delivery loop
- if (DBA::isResult($r)) {
- foreach ($r as $contact) {
- logger("Deliver ".$item_id." to ".$contact['url']." via network ".$contact['network'], LOGGER_DEBUG);
-
- Worker::add(['priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true],
- 'Delivery', $cmd, $item_id, (int)$contact['id']);
- }
+ $result = DBA::select('contact', ['id', 'url', 'network', 'batch'], $condition);
+ $contacts = DBA::toArray($result);