<?php

require_once __DIR__ . '/../include/init.php';

$queue = Journal_Abonnements::getQueue();
$journal = null;

foreach ($queue as $q)
{
	if (is_null($journal) || $journal->get('id') != $q['journal'])
	{
		$journal = new Journal($q['journal']);
		$abo = new Journal_Abonnements($journal);
		$abonnes = $abo->getList();
	}

	$abo->send(Ecrit::get($q['journal'], $q['ecrit']), $abonnes);
	Journal_Abonnements::removeFromQueue($q['ecrit']);
}

?>