tests with Apache ActiveMQ topics (pubsub)

This commit is contained in:
Federico Marani 2009-03-07 13:48:39 +00:00
parent 80d0423026
commit a389f157ba

View File

@ -1159,6 +1159,20 @@ function common_enqueue_notice($notice)
}
common_log(LOG_DEBUG, 'complete remote queueing notice ID = ' . $notice->id . ' for ' . $transport);
}
$con->send('/topic/laconica.'.$notice->profile_id,
$notice->content,
array(
'profile_id' => $notice->profile_id,
'created' => $notice->created
)
);
$con->send('/topic/laconica.allusers',
$notice->content,
array(
'profile_id' => $notice->profile_id,
'created' => $notice->created
)
);
$result = true;
}
else {