summaryrefslogtreecommitdiff
path: root/plugins/OStatus/lib/hubdistribqueuehandler.php
diff options
context:
space:
mode:
authorEvan Prodromou <evan@status.net>2010-02-21 21:39:50 -0500
committerEvan Prodromou <evan@status.net>2010-02-21 21:39:50 -0500
commit273c0e036347891570a02502715345f5bbb7b143 (patch)
tree489c1a254e4698443e30032b0a37226259b9c958 /plugins/OStatus/lib/hubdistribqueuehandler.php
parent912814fb7f3580e6925b5fae7092966df9bf3aab (diff)
parentca2a88545d353f0e887f48fe0e3bd43b505031ca (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);
}
}