summaryrefslogtreecommitdiff
path: root/plugins/OStatus/lib/hubdistribqueuehandler.php
diff options
context:
space:
mode:
authorBrion Vibber <brion@pobox.com>2010-02-21 14:28:06 -0800
committerBrion Vibber <brion@pobox.com>2010-02-21 14:28:06 -0800
commitaa0b2ce81ad4a99fb55a36feda54e70bcd0808be (patch)
treea717518d378806729d40e6032e83eb2499d94a73 /plugins/OStatus/lib/hubdistribqueuehandler.php
parent37179a91d5e176a743453cf27de606553bd62f36 (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.php5
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);
}
}