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