mmucklo /
DtcQueueBundle
| @@ 43-56 (lines=14) @@ | ||
| 40 | } |
|
| 41 | } |
|
| 42 | ||
| 43 | public function testLater() |
|
| 44 | { |
|
| 45 | $time = null; |
|
| 46 | $job = $this->worker->later()->fibonacci(20); |
|
| 47 | self::assertJob($job, $time, 'fibonacci'); |
|
| 48 | self::assertFalse($job->getBatch(), 'Should not be batching'); |
|
| 49 | ||
| 50 | // Test later with priority |
|
| 51 | $priority = 1024; |
|
| 52 | $job = $this->worker->later(0, $priority)->fibonacci(20); |
|
| 53 | self::assertJob($job, $time, 'fibonacci', $priority); |
|
| 54 | ||
| 55 | $this->failureTest($time, 'later'); |
|
| 56 | } |
|
| 57 | ||
| 58 | public function testBatchLater() |
|
| 59 | { |
|
| @@ 58-71 (lines=14) @@ | ||
| 55 | $this->failureTest($time, 'later'); |
|
| 56 | } |
|
| 57 | ||
| 58 | public function testBatchLater() |
|
| 59 | { |
|
| 60 | $time = null; |
|
| 61 | $job = $this->worker->batchLater()->fibonacci(20); |
|
| 62 | self::assertJob($job, $time, 'fibonacci'); |
|
| 63 | self::assertTrue($job->getBatch(), 'Should be batching'); |
|
| 64 | ||
| 65 | // Test batchLater with priority |
|
| 66 | $priority = 1024; |
|
| 67 | $job = $this->worker->batchLater(0, $priority)->fibonacci(20); |
|
| 68 | self::assertJob($job, $time, 'fibonacci', $priority); |
|
| 69 | ||
| 70 | $this->failureTest($time, 'batchLater'); |
|
| 71 | } |
|
| 72 | ||
| 73 | protected function failureTest($method, $time) |
|
| 74 | { |
|
| @@ 85-98 (lines=14) @@ | ||
| 82 | } |
|
| 83 | } |
|
| 84 | ||
| 85 | public function testBatchAt() |
|
| 86 | { |
|
| 87 | $time = time() + 3600; |
|
| 88 | $job = $this->worker->batchAt($time)->fibonacci(20); |
|
| 89 | self::assertJob($job, $time, 'fibonacci'); |
|
| 90 | self::assertTrue($job->getBatch(), 'Should be batching'); |
|
| 91 | ||
| 92 | // Test priority |
|
| 93 | $priority = 1024; |
|
| 94 | $job = $this->worker->batchAt($time, $priority)->fibonacci(20); |
|
| 95 | self::assertJob($job, $time, 'fibonacci', $priority); |
|
| 96 | ||
| 97 | $this->failureTest($time, 'batchAt'); |
|
| 98 | } |
|
| 99 | ||
| 100 | /** |
|
| 101 | * @param int|null $time |
|
