GNUsocial/gnu-social
4
0
Fork 1
Code Issues Releases Wiki Activity

Testing JMS message selectors for notice tags-based routing

Browse Source
This commit is contained in:
Federico Marani 2009-03-28 17:55:20 +00:00
parent 4b3f022fc2
commit 5e9ff6ae97
1 changed files with 20 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
lib/util.php
View File

@ -868,20 +868,38 @@ function common_enqueue_notice($notice)
} }
common_log(LOG_DEBUG, 'complete remote queueing notice ID = ' . $notice->id . ' for ' . $transport); common_log(LOG_DEBUG, 'complete remote queueing notice ID = ' . $notice->id . ' for ' . $transport);
} }
//send tags as headers, so they can be used as JMS selectors
common_log(LOG_DEBUG, 'searching for tags ' . $notice->id);
$tags = array();
$tag = new Notice_tag();
$tag->notice_id = $notice->id;
if ($tag->find()) {
while ($tag->fetch()) {
common_log(LOG_DEBUG, 'tag found = ' . $tag->tag);
array_push($tags,$tag->tag);
}
}
$tag->free();
$con->send('/topic/laconica.'.$notice->profile_id, $con->send('/topic/laconica.'.$notice->profile_id,
$notice->content, $notice->content,
array( array(
'profile_id' => $notice->profile_id, 'profile_id' => $notice->profile_id,
'created' => $notice->created 'created' => $notice->created,
'tags' => implode($tags,' - ')
) )
); );
common_log(LOG_DEBUG, 'sent to personal topic ' . $notice->id);
$con->send('/topic/laconica.allusers', $con->send('/topic/laconica.allusers',
$notice->content, $notice->content,
array( array(
'profile_id' => $notice->profile_id, 'profile_id' => $notice->profile_id,
'created' => $notice->created 'created' => $notice->created,
'tags' => implode($tags,' - ')
) )
); );
common_log(LOG_DEBUG, 'sent to catch-all topic ' . $notice->id);
$result = true; $result = true;
} }
else { else {