@@ -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 |
@@ -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 | |
@@ -15,12 +15,12 @@ |
||
| 15 | 15 | |
| 16 | 16 | public function __construct(AMQPConnection $connection) { |
| 17 | 17 | $this->connection = $connection; |
| 18 | - $this->channel = $connection->channel();; |
|
| 18 | + $this->channel = $connection->channel(); ; |
|
| 19 | 19 | } |
| 20 | 20 | |
| 21 | 21 | public function save($job) { |
| 22 | 22 | $queue = $job->getWorkerName(); |
| 23 | - $exchange = null; // User default exchange |
|
| 23 | + $exchange = null; // User default exchange |
|
| 24 | 24 | |
| 25 | 25 | $this->channel->queue_declare($queue, false, true, false, false); |
| 26 | 26 | $this->channel->exchange_declare($exchange, 'direct', false, true, false); |
@@ -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 |
@@ -83,7 +83,7 @@ |
||
| 83 | 83 | public function testPerformance() { |
| 84 | 84 | $start = microtime(true); |
| 85 | 85 | $jobsTotal = 1000; |
| 86 | - self::$jobManager->enableSorting = false; // Ignore priority |
|
| 86 | + self::$jobManager->enableSorting = false; // Ignore priority |
|
| 87 | 87 | |
| 88 | 88 | for ($i = 0; $i < $jobsTotal; $i++) { |
| 89 | 89 | self::$worker->later()->fibonacci(1); |
@@ -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 |
@@ -13,7 +13,7 @@ |
||
| 13 | 13 | $worker = new FibonacciWorker(); |
| 14 | 14 | $job = new Job($worker, false, null); |
| 15 | 15 | $job->setArgs(array(1)); |
| 16 | - $job->setArgs(array(1, array(1,2))); |
|
| 16 | + $job->setArgs(array(1, array(1, 2))); |
|
| 17 | 17 | |
| 18 | 18 | try { |
| 19 | 19 | $job->setArgs(array($job)); |
@@ -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 |
@@ -15,7 +15,7 @@ discard block |
||
| 15 | 15 | |
| 16 | 16 | public function hasListeners($eventName) |
| 17 | 17 | { |
| 18 | - if ( ! isset($this->listeners[$eventName])) { |
|
| 18 | + if (!isset($this->listeners[$eventName])) { |
|
| 19 | 19 | return false; |
| 20 | 20 | } |
| 21 | 21 | |
@@ -24,7 +24,7 @@ discard block |
||
| 24 | 24 | |
| 25 | 25 | public function dispatch($eventName, Event $event) |
| 26 | 26 | { |
| 27 | - if ( ! isset($this->listeners[$eventName])) { |
|
| 27 | + if (!isset($this->listeners[$eventName])) { |
|
| 28 | 28 | return; |
| 29 | 29 | } |
| 30 | 30 | |