]>
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 :). | |
24 | */ | |
25 | public function isStopJob($job) | |
26 | { | |
27 | return false; | |
ef75e122 JB |
28 | } |
29 | } |