summaryrefslogtreecommitdiff
path: root/plugins/OStatus/lib/hubdistribqueuehandler.php
diff options
context:
space:
mode:
authorZach Copley <zach@status.net>2010-02-21 14:44:28 -0800
committerZach Copley <zach@status.net>2010-02-21 14:44:28 -0800
commitca2a88545d353f0e887f48fe0e3bd43b505031ca (patch)
treee8b0d4ef406ce49a8df1991dc5d2abba14179111 /plugins/OStatus/lib/hubdistribqueuehandler.php
parent10281d59f4bf8298ff65792d1a7826913d96fafa (diff)
parentaa0b2ce81ad4a99fb55a36feda54e70bcd0808be (diff)
Merge branch 'testing' of git@gitorious.org:statusnet/mainline into testing
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);
}
}