diff options
Diffstat (limited to 'src/Wallabag/ImportBundle/Consumer')
-rw-r--r-- | src/Wallabag/ImportBundle/Consumer/RedisEntryConsumer.php | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/src/Wallabag/ImportBundle/Consumer/RedisEntryConsumer.php b/src/Wallabag/ImportBundle/Consumer/RedisEntryConsumer.php index 450b71ff..862d0c43 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 | |||
21 | /** | 21 | /** |
22 | * Should tell if the given job will kill the worker. | 22 | * Should tell if the given job will kill the worker. |
23 | * We don't want to stop it :). | 23 | * We don't want to stop it :). |
24 | * | ||
25 | * @param string $job Content of the message (directly from Redis) | ||
26 | * | ||
27 | * @return false | ||
24 | */ | 28 | */ |
25 | public function isStopJob($job) | 29 | public function isStopJob($job) |
26 | { | 30 | { |
27 | return false; | 31 | return false; |
28 | } | 32 | } |
33 | |||
34 | /** | ||
35 | * This abstract method is only used when we use one queue for multiple job type. | ||
36 | * We don't do that, so we'll always return true. | ||
37 | * | ||
38 | * @param string $job Content of the message (directly from Redis) | ||
39 | * | ||
40 | * @return true | ||
41 | */ | ||
42 | public function isMyJob($job) | ||
43 | { | ||
44 | return true; | ||
45 | } | ||
29 | } | 46 | } |