summaryrefslogtreecommitdiff
path: root/scripts/inboxqueuehandler.php
diff options
context:
space:
mode:
authorEvan Prodromou <evan@controlyourself.ca>2009-05-28 18:19:22 -0400
committerEvan Prodromou <evan@controlyourself.ca>2009-05-28 18:19:22 -0400
commit3532cd0490a70b54a92108549de6042459fd8469 (patch)
tree13e0aa7b5fd7da79867d304850a27753df212424 /scripts/inboxqueuehandler.php
parent047038959c068364f2efa030ba63571a492b9cda (diff)
Only enqueue inbox-dependent transports after inboxes have been filled
Diffstat (limited to 'scripts/inboxqueuehandler.php')
-rwxr-xr-xscripts/inboxqueuehandler.php10
1 files changed, 9 insertions, 1 deletions
diff --git a/scripts/inboxqueuehandler.php b/scripts/inboxqueuehandler.php
index 73d31e854..c7aab4fe1 100755
--- a/scripts/inboxqueuehandler.php
+++ b/scripts/inboxqueuehandler.php
@@ -41,7 +41,7 @@ class InboxQueueHandler extends QueueHandler
}
function start() {
- $this->log(LOG_INFO, "INITIALIZE");
+ $this->log(LOG_INFO, "Initialize inbox queue handler");
return true;
}
@@ -49,11 +49,19 @@ class InboxQueueHandler extends QueueHandler
{
$this->log(LOG_INFO, "Distributing notice to inboxes for $notice->id");
$notice->addToInboxes();
+ $notice->saveGroups();
$notice->blowSubsCache();
+ $transports = common_post_inbox_transports();
+
+ foreach ($transports as $transport) {
+ common_enqueue_notice_transport($notice, $transport);
+ }
+
return true;
}
function finish() {
+ $this->log(LOG_INFO, "Terminating inbox queue handler");
}
}