- // We'll push to each subscriber that has push > 0,
- // i.e. there has been an update (set in notifier.php).
- $r = q("SELECT `id`, `callback_url` FROM `push_subscriber` WHERE `push` > 0 ORDER BY `last_update` DESC");
-
- foreach ($r as $rr) {
- logger("Publish feed to ".$rr["callback_url"], LOGGER_DEBUG);
- Worker::add(['priority' => PRIORITY_HIGH, 'created' => $a->queue['created'], 'dont_fork' => true],
- 'PubSubPublish', (int)$rr["id"]);
- }