1 | <?php |
||
8 | class BeanstalkDriver implements DriverInterface |
||
9 | { |
||
10 | /** |
||
11 | * @var Pheanstalk |
||
12 | */ |
||
13 | private $beanstalk; |
||
14 | |||
15 | /** |
||
16 | * @param Pheanstalk $beanstalk |
||
17 | */ |
||
18 | 4 | public function __construct(Pheanstalk $beanstalk) |
|
22 | |||
23 | /** |
||
24 | * @inheritdoc |
||
25 | */ |
||
26 | 1 | public function enqueue($queue, $command) |
|
32 | |||
33 | /** |
||
34 | * @inheritdoc |
||
35 | */ |
||
36 | 2 | public function dequeue($queue) |
|
37 | { |
||
38 | 2 | $job = $this->beanstalk |
|
39 | 2 | ->watch($queue) |
|
40 | 2 | ->ignore('default') |
|
41 | 2 | ->reserve(static::TIMEOUT); |
|
42 | |||
43 | 2 | $data = $job instanceof Job ? $job->getData() : $job; |
|
44 | return [ |
||
45 | 2 | unserialize($data), |
|
46 | 2 | $job, |
|
47 | 2 | ]; |
|
48 | } |
||
49 | |||
50 | /** |
||
51 | * @inheritdoc |
||
52 | */ |
||
53 | 1 | public function processed($job) |
|
57 | } |
||
58 |