diff --git a/composer.json b/composer.json index d1f970c79..ae7108f06 100644 --- a/composer.json +++ b/composer.json @@ -80,7 +80,7 @@ "white-october/pagerfanta-bundle": "^1.0", "php-amqplib/rabbitmq-bundle": "^1.8", "predis/predis": "^1.0", - "javibravo/simpleue": "^1.0", + "javibravo/simpleue": "^2.0", "symfony/dom-crawler": "^3.1", "friendsofsymfony/jsrouting-bundle": "^1.6", "bdunogier/guzzle-site-authenticator": "^1.0.0@dev", diff --git a/src/Wallabag/ImportBundle/Consumer/RedisEntryConsumer.php b/src/Wallabag/ImportBundle/Consumer/RedisEntryConsumer.php index 450b71ffd..862d0c43c 100644 --- a/src/Wallabag/ImportBundle/Consumer/RedisEntryConsumer.php +++ b/src/Wallabag/ImportBundle/Consumer/RedisEntryConsumer.php @@ -21,9 +21,26 @@ class RedisEntryConsumer extends AbstractConsumer implements Job /** * Should tell if the given job will kill the worker. * We don't want to stop it :). + * + * @param string $job Content of the message (directly from Redis) + * + * @return false */ public function isStopJob($job) { return false; } + + /** + * This abstract method is only used when we use one queue for multiple job type. + * We don't do that, so we'll always return true. + * + * @param string $job Content of the message (directly from Redis) + * + * @return true + */ + public function isMyJob($job) + { + return true; + } }