1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
namespace Dtc\QueueBundle\Tests\Beanstalkd; |
4
|
|
|
|
5
|
|
|
use Dtc\QueueBundle\Beanstalkd\Job; |
6
|
|
|
use Dtc\QueueBundle\Tests\FibonacciWorker; |
7
|
|
|
use Dtc\QueueBundle\Tests\GetterSetterTrait; |
8
|
|
|
use PHPUnit\Framework\TestCase; |
9
|
|
|
|
10
|
|
|
class JobTest extends TestCase |
11
|
|
|
{ |
12
|
|
|
use GetterSetterTrait; |
13
|
|
|
|
14
|
|
|
public function testGettersSetters() |
15
|
|
|
{ |
16
|
|
|
$this->runGetterSetterTests('\Dtc\QueueBundle\Beanstalkd\Job'); |
17
|
|
|
} |
18
|
|
|
|
19
|
|
|
public function testToFromMessage() |
20
|
|
|
{ |
21
|
|
|
$worker = new FibonacciWorker(); |
22
|
|
|
$job = new Job($worker, false, null); |
23
|
|
|
$job->setArgs([1, 2, 3]); |
24
|
|
|
$job->setMethod('asdf'); |
25
|
|
|
$job->setPriority(1234); |
26
|
|
|
$message = $job->toMessage(); |
27
|
|
|
|
28
|
|
|
$job2 = new Job(); |
29
|
|
|
$priority2 = $job2->getPriority(); |
30
|
|
|
$job2->fromMessage($message); |
31
|
|
|
|
32
|
|
|
self::assertEquals($job->getMethod(), $job2->getMethod()); |
33
|
|
|
self::assertEquals($job->getWorkerName(), $job2->getWorkerName()); |
34
|
|
|
self::assertEquals($job->getArgs(), $job2->getArgs()); |
35
|
|
|
self::assertEquals($priority2, $job2->getPriority()); |
36
|
|
|
|
37
|
|
|
$worker = new FibonacciWorker(); |
38
|
|
|
$job = new Job($worker, false, null); |
39
|
|
|
$job->setArgs([1, 2, 3]); |
40
|
|
|
$job->setMethod('asdf'); |
41
|
|
|
$job->setPriority(1234); |
42
|
|
|
$date = new \DateTime(); |
43
|
|
|
$job->setExpiresAt($date); |
44
|
|
|
$message = $job->toMessage(); |
45
|
|
|
|
46
|
|
|
$job2 = new Job(); |
47
|
|
|
$priority2 = $job2->getPriority(); |
48
|
|
|
$job2->fromMessage($message); |
49
|
|
|
|
50
|
|
|
self::assertEquals($job->getMethod(), $job2->getMethod()); |
51
|
|
|
self::assertEquals($job->getWorkerName(), $job2->getWorkerName()); |
52
|
|
|
self::assertEquals($job->getArgs(), $job2->getArgs()); |
53
|
|
|
self::assertEquals($priority2, $job2->getPriority()); |
54
|
|
|
self::assertEquals($job->getExpiresAt(), $job2->getExpiresAt()); |
55
|
|
|
} |
56
|
|
|
} |
57
|
|
|
|