XXX comments to remember to fan-out in realtime distribution
This commit is contained in:
parent
a602477a1d
commit
641749453d
@ -209,6 +209,9 @@ class RealtimePlugin extends Plugin
|
|||||||
$json = $this->noticeAsJson($notice);
|
$json = $this->noticeAsJson($notice);
|
||||||
|
|
||||||
$this->_connect();
|
$this->_connect();
|
||||||
|
|
||||||
|
// XXX: We should probably fan-out here and do a
|
||||||
|
// new queue item for each path
|
||||||
|
|
||||||
foreach ($paths as $path) {
|
foreach ($paths as $path) {
|
||||||
|
|
||||||
@ -217,6 +220,10 @@ class RealtimePlugin extends Plugin
|
|||||||
$channels = Realtime_channel::getAllChannels($action, $arg1, $arg2);
|
$channels = Realtime_channel::getAllChannels($action, $arg1, $arg2);
|
||||||
|
|
||||||
foreach ($channels as $channel) {
|
foreach ($channels as $channel) {
|
||||||
|
|
||||||
|
// XXX: We should probably fan-out here and do a
|
||||||
|
// new queue item for each user/path combo
|
||||||
|
|
||||||
if (is_null($channel->user_id)) {
|
if (is_null($channel->user_id)) {
|
||||||
$profile = null;
|
$profile = null;
|
||||||
} else {
|
} else {
|
||||||
|
Loading…
Reference in New Issue
Block a user