$cola = new clMensajes(API_MENSAJES, USU_MENSAJES);
$idTema = $cola->buscarTema('UN_TOPICO');
if(!$idTema)
$idTema = $cola->crearTema('UN_TOPICO');
$cola->suscribir($idTema);
$cola->publicar($idTema, 'Mensaje de prueba', 'Esto es un mensaje de prueba', 120);
for($i = 0; $i < 10; $i++) {
try {
$mensajes = $cola->leerPublicaciones();
foreach($mensajes as $unMensaje) {
procesar($unMensaje);
}
} catch(Exception $e) {
echo 'Error '.$e->getCode().': '.$e->getMessage().PHP_EOL;
}
}