diff options
author | Brion Vibber <brion@pobox.com> | 2010-02-21 14:28:06 -0800 |
---|---|---|
committer | Brion Vibber <brion@pobox.com> | 2010-02-21 14:28:06 -0800 |
commit | aa0b2ce81ad4a99fb55a36feda54e70bcd0808be (patch) | |
tree | a717518d378806729d40e6032e83eb2499d94a73 /plugins/OStatus/lib/hubdistribqueuehandler.php | |
parent | 37179a91d5e176a743453cf27de606553bd62f36 (diff) |
OStatus PuSH fixlets:
- set minimal error page output on PuSH callback
- allow hub to retry ($config['ostatus']['hub_retries']), simplify internal iface a bit. Retries are pushed to end of queue but otherwise not delayed yet; makes delivery more robust to one-off transitory errors but not yet against downtime.
Diffstat (limited to 'plugins/OStatus/lib/hubdistribqueuehandler.php')
-rw-r--r-- | plugins/OStatus/lib/hubdistribqueuehandler.php | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/plugins/OStatus/lib/hubdistribqueuehandler.php b/plugins/OStatus/lib/hubdistribqueuehandler.php index 245a57f72..30a427e3f 100644 --- a/plugins/OStatus/lib/hubdistribqueuehandler.php +++ b/plugins/OStatus/lib/hubdistribqueuehandler.php @@ -124,10 +124,7 @@ class HubDistribQueueHandler extends QueueHandler common_log(LOG_INFO, "Preparing $sub->N PuSH distribution(s) for $sub->topic"); $qm = QueueManager::get(); while ($sub->fetch()) { - common_log(LOG_INFO, "Prepping PuSH distribution to $sub->callback for $sub->topic"); - $data = array('sub' => clone($sub), - 'atom' => $atom); - $qm->enqueue($data, 'hubout'); + $sub->distribute($atom); } } |