@@ -2,11 +2,9 @@ |
||
2 | 2 | namespace Dtc\QueueBundle\Command; |
3 | 3 | |
4 | 4 | use Dtc\QueueBundle\Documents\Job; |
5 | - |
|
6 | 5 | use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand; |
7 | 6 | use Symfony\Component\Console\Input\InputArgument; |
8 | 7 | use Symfony\Component\Console\Input\InputInterface; |
9 | -use Symfony\Component\Console\Input\InputOption; |
|
10 | 8 | use Symfony\Component\Console\Output\OutputInterface; |
11 | 9 | |
12 | 10 | class CreateJobCommand |
@@ -2,9 +2,7 @@ |
||
2 | 2 | namespace Dtc\QueueBundle\Command; |
3 | 3 | |
4 | 4 | use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand; |
5 | -use Symfony\Component\Console\Input\InputArgument; |
|
6 | 5 | use Symfony\Component\Console\Input\InputInterface; |
7 | -use Symfony\Component\Console\Input\InputOption; |
|
8 | 6 | use Symfony\Component\Console\Output\OutputInterface; |
9 | 7 | |
10 | 8 | class PruneCommand |
@@ -3,10 +3,7 @@ |
||
3 | 3 | |
4 | 4 | use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route; |
5 | 5 | use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template; |
6 | - |
|
7 | 6 | use Symfony\Bundle\FrameworkBundle\Controller\Controller; |
8 | -use Symfony\Component\HttpFoundation\Response; |
|
9 | -use Symfony\Component\HttpFoundation\Request; |
|
10 | 7 | |
11 | 8 | class QueueController |
12 | 9 | extends Controller |
@@ -11,6 +11,9 @@ |
||
11 | 11 | protected $dm; |
12 | 12 | protected $documentName; |
13 | 13 | |
14 | + /** |
|
15 | + * @param string $documentName |
|
16 | + */ |
|
14 | 17 | public function __construct(DocumentManager $dm, $documentName) |
15 | 18 | { |
16 | 19 | $this->dm = $dm; |
@@ -33,6 +33,9 @@ |
||
33 | 33 | return $job; |
34 | 34 | } |
35 | 35 | |
36 | + /** |
|
37 | + * @param string $workerName |
|
38 | + */ |
|
36 | 39 | public function getJob($workerName = null, $methodName = null, $prioritize = true) |
37 | 40 | { |
38 | 41 | if ($methodName) { |
@@ -3,7 +3,6 @@ |
||
3 | 3 | |
4 | 4 | use Dtc\QueueBundle\Model\Job as BaseJob; |
5 | 5 | use Dtc\QueueBundle\Model\JobManagerInterface; |
6 | - |
|
7 | 6 | use PhpAmqpLib\Connection\AMQPConnection; |
8 | 7 | use PhpAmqpLib\Message\AMQPMessage; |
9 | 8 |
@@ -2,9 +2,6 @@ |
||
2 | 2 | namespace Dtc\QueueBundle\Tests\Model; |
3 | 3 | |
4 | 4 | use Dtc\QueueBundle\Model\Job; |
5 | -use Dtc\QueueBundle\Tests\FibonacciWorker; |
|
6 | -use Dtc\QueueBundle\Tests\StaticJobManager; |
|
7 | -use Dtc\QueueBundle\Model\WorkerManager; |
|
8 | 5 | |
9 | 6 | class BaseJobManagerTest |
10 | 7 | extends \PHPUnit_Framework_TestCase |
@@ -4,7 +4,6 @@ |
||
4 | 4 | use Dtc\QueueBundle\Model\Job; |
5 | 5 | use Dtc\QueueBundle\Tests\FibonacciWorker; |
6 | 6 | use Dtc\QueueBundle\Tests\StaticJobManager; |
7 | -use Dtc\QueueBundle\Model\WorkerManager; |
|
8 | 7 | |
9 | 8 | class JobTest |
10 | 9 | extends \PHPUnit_Framework_TestCase |
@@ -104,6 +104,11 @@ |
||
104 | 104 | } |
105 | 105 | } |
106 | 106 | |
107 | + /** |
|
108 | + * @param integer|null $time |
|
109 | + * @param string $method |
|
110 | + * @param integer $priority |
|
111 | + */ |
|
107 | 112 | protected function assertJob(Job $job, $time, $method, $priority = null) { |
108 | 113 | $this->assertNotEmpty($job->getId(), "Job should have an id"); |
109 | 114 |
@@ -4,7 +4,6 @@ |
||
4 | 4 | use Dtc\QueueBundle\Model\Job; |
5 | 5 | use Dtc\QueueBundle\Tests\FibonacciWorker; |
6 | 6 | use Dtc\QueueBundle\Tests\StaticJobManager; |
7 | -use Dtc\QueueBundle\Model\WorkerManager; |
|
8 | 7 | |
9 | 8 | class WorkerTest |
10 | 9 | extends \PHPUnit_Framework_TestCase |
@@ -3,14 +3,9 @@ |
||
3 | 3 | |
4 | 4 | use Dtc\QueueBundle\RabbitMQ\JobManager; |
5 | 5 | use Dtc\QueueBundle\Model\Job; |
6 | -use Dtc\QueueBundle\Model\WorkerManager; |
|
7 | - |
|
8 | 6 | use Dtc\QueueBundle\Tests\FibonacciWorker; |
9 | -use Dtc\QueueBundle\Tests\StaticJobManager; |
|
10 | 7 | use Dtc\QueueBundle\Tests\Model\BaseJobManagerTest; |
11 | - |
|
12 | 8 | use PhpAmqpLib\Connection\AMQPConnection; |
13 | -use PhpAmqpLib\Message\AMQPMessage; |
|
14 | 9 | |
15 | 10 | /** |
16 | 11 | * @author David |