src/Wallabag/ImportBundle/Consumer/RedisEntryConsumer.php

   1 <?php
   2
   3 namespace Wallabag\ImportBundle\Consumer;
   4
   5 use Simpleue\Job\Job;
   6
   7 class RedisEntryConsumer extends AbstractConsumer implements Job
   8 {
   9     /**
  10      * Handle one message by one message.
  11      *
  12      * @param string $job Content of the message (directly from Redis)
  13      *
  14      * @return bool
  15      */
  16     public function manage($job)
  17     {
  18         return $this->handleMessage($job);
  19     }
  20
  21     /**
  22      * Should tell if the given job will kill the worker.
  23      * We don't want to stop it :).
  24      */
  25     public function isStopJob($job)
  26     {
  27         return false;
  28     }
  29 }