diff options
| author | Evan Prodromou <evan@prodromou.name> | 2008-08-29 14:17:02 -0400 |
|---|---|---|
| committer | Evan Prodromou <evan@prodromou.name> | 2008-08-29 14:17:02 -0400 |
| commit | c4d67892751b17856b235182874c3304890dc2c3 (patch) | |
| tree | b31fa8766cfaa2e906cf19862af5bfa50390e6cd /lib/util.php | |
| parent | f652418863182182bb17e0f378194a8648392410 (diff) | |
split public stream to its own queue handler
Add another queue handler for the public stream. Should further
parallelize the work of sending out messages.
darcs-hash:20080829181702-84dde-594505aa73d2380b13bd98917b70b02bac597d12.gz
Diffstat (limited to 'lib/util.php')
| -rw-r--r-- | lib/util.php | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/lib/util.php b/lib/util.php index 496c6f3d2..c6cdfbcb9 100644 --- a/lib/util.php +++ b/lib/util.php @@ -1070,7 +1070,7 @@ function common_broadcast_notice($notice, $remote=false) { # Stick the notice on the queue function common_enqueue_notice($notice) { - foreach (array('jabber', 'omb', 'sms') as $transport) { + foreach (array('jabber', 'omb', 'sms', 'public') as $transport) { $qi = new Queue_item(); $qi->notice_id = $notice->id; $qi->transport = $transport; @@ -1126,6 +1126,12 @@ function common_real_broadcast($notice, $remote=false) { common_log(LOG_ERR, 'Error in sms broadcast for notice ' . $notice->id); } } + if ($success) { + $success = jabber_public_notice($notice); + if (!$success) { + common_log(LOG_ERR, 'Error in public broadcast for notice ' . $notice->id); + } + } // XXX: broadcast notices to other IM return $success; } |