Added autoflush to worker

This commit is contained in:
Frederic Guillot 2016-05-16 21:58:56 -04:00
parent d964c97f90
commit 03dbc3e17d

View File

@ -38,6 +38,9 @@ while ($job = $connection->reserveFromTube(BEANSTALKD_QUEUE)) {
echo 'Processing feed_id=', $feed_id, PHP_EOL; echo 'Processing feed_id=', $feed_id, PHP_EOL;
Model\Feed\refresh($feed_id); Model\Feed\refresh($feed_id);
Model\Item\autoflush_read();
Model\Item\autoflush_unread();
$connection->delete($job); $connection->delete($job);
check_job_left($connection, $options); check_job_left($connection, $options);