mmucklo / DtcQueueBundle

Command/CreateJobCommand.php

Unused Use Statements -2 removed lines

@@ -2,11 +2,9 @@
 namespace Dtc\QueueBundle\Command;
 
 use Dtc\QueueBundle\Documents\Job;
-
 use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputInterface;
-use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
 
 class CreateJobCommand

Command/PruneCommand.php

Unused Use Statements -2 removed lines

@@ -2,9 +2,7 @@
 namespace Dtc\QueueBundle\Command;
 
 use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
-use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputInterface;
-use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
 
 class PruneCommand

Controller/QueueController.php

Unused Use Statements -3 removed lines

@@ -3,10 +3,7 @@
 
 use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
 use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
-
 use Symfony\Bundle\FrameworkBundle\Controller\Controller;
-use Symfony\Component\HttpFoundation\Response;
-use Symfony\Component\HttpFoundation\Request;
 
 class QueueController
     extends Controller

Documents/JobManager.php

Doc Comments +3 added lines

@@ -11,6 +11,9 @@
     protected $dm;
     protected $documentName;
 
+    /**
+     * @param string $documentName
+     */
     public function __construct(DocumentManager $dm, $documentName)
     {
         $this->dm = $dm;

Braces +1 added lines, -2 removed lines

@@ -115,8 +115,7 @@
         if ($priority) {
             $this->assertEquals($priority, $job->getPriority(),
                     "Priority should be the same.");
-        }
-        else {
+        } else {
             $this->assertNull($job->getPriority(), "Priority should be null");
         }
 

Model/Worker.php

Doc Comments +12 added lines, -2 removed lines

@@ -16,7 +16,7 @@ 
     }
 
     /**
-     * @param field_type $jobClass
+     * @param string $jobClass
      */
     public function setJobClass($jobClass)
     {
@@ -29,7 +29,7 @@ 
     }
 
     /**
-     * @return the $jobManager
+     * @return JobManagerInterface $jobManager
      */
     public function getJobManager()
     {
@@ -53,6 +53,9 @@ 
         return new $this->jobClass($this, $batch, $priority, $dateTime);
     }
 
+    /**
+     * @param integer $priority
+     */
     public function later($delay = 0, $priority = null)
     {
         $job = $this->at(time() + $delay, false, $priority);
@@ -60,6 +63,9 @@ 
         return $job;
     }
 
+    /**
+     * @param integer $priority
+     */
     public function batchLater($delay = 0, $priority = null)
     {
         $job = $this->at($delay, true, $priority);
@@ -67,6 +73,10 @@ 
         return $job;
     }
 
+    /**
+     * @param integer $time
+     * @param integer $priority
+     */
     public function batchAt($time = null, $priority = null)
     {
         return $this->at($time, true, $priority);

Braces +1 added lines, -2 removed lines

@@ -115,8 +115,7 @@
         if ($priority) {
             $this->assertEquals($priority, $job->getPriority(),
                     "Priority should be the same.");
-        }
-        else {
+        } else {
             $this->assertNull($job->getPriority(), "Priority should be null");
         }
 

RabbitMQ/JobManager.php

Doc Comments +3 added lines

@@ -33,6 +33,9 @@
         return $job;
     }
 
+    /**
+     * @param string $workerName
+     */
     public function getJob($workerName = null, $methodName = null, $prioritize = true)
     {
         if ($methodName) {

Unused Use Statements -1 removed lines

@@ -3,7 +3,6 @@
 
 use Dtc\QueueBundle\Model\Job as BaseJob;
 use Dtc\QueueBundle\Model\JobManagerInterface;
-
 use PhpAmqpLib\Connection\AMQPConnection;
 use PhpAmqpLib\Message\AMQPMessage;
 

Spacing +2 added lines, -2 removed lines

@@ -15,12 +15,12 @@
 
     public function __construct(AMQPConnection $connection) {
         $this->connection = $connection;
-        $this->channel = $connection->channel();;
+        $this->channel = $connection->channel(); ;
     }
 
     public function save($job) {
         $queue = $job->getWorkerName();
-        $exchange = null; 	// User default exchange
+        $exchange = null; // User default exchange
 
         $this->channel->queue_declare($queue, false, true, false, false);
         $this->channel->exchange_declare($exchange, 'direct', false, true, false);

Braces +1 added lines, -2 removed lines

@@ -115,8 +115,7 @@
         if ($priority) {
             $this->assertEquals($priority, $job->getPriority(),
                     "Priority should be the same.");
-        }
-        else {
+        } else {
             $this->assertNull($job->getPriority(), "Priority should be null");
         }
 

Tests/BeanStalkd/JobManagerTest.php

Unused Use Statements -3 removed lines

@@ -3,10 +3,7 @@
 
 use Dtc\QueueBundle\BeanStalkd\JobManager;
 use Dtc\QueueBundle\Model\Job;
-use Dtc\QueueBundle\Model\WorkerManager;
-
 use Dtc\QueueBundle\Tests\FibonacciWorker;
-use Dtc\QueueBundle\Tests\StaticJobManager;
 use Dtc\QueueBundle\Tests\Model\BaseJobManagerTest;
 
 /**

Tests/Documents/JobManagerTest.php

Unused Use Statements -4 removed lines

@@ -3,12 +3,8 @@
 
 use Dtc\QueueBundle\Tests\Model\BaseJobManagerTest;
 use Dtc\QueueBundle\Tests\FibonacciWorker;
-use Dtc\QueueBundle\Tests\StaticJobManager;
-
-use Dtc\QueueBundle\Model\WorkerManager;
 use Dtc\QueueBundle\Documents\JobManager;
 use Dtc\QueueBundle\Model\Job;
-
 use Doctrine\MongoDB\Connection;
 use Doctrine\ODM\MongoDB\Configuration;
 use Doctrine\ODM\MongoDB\DocumentManager;

Spacing +2 added lines, -2 removed lines

@@ -41,14 +41,14 @@
         $config->setHydratorDir('/tmp/dtcqueuetest/generate/hydrators');
         $config->setHydratorNamespace('Hydrators');
 
-        $classPath = __DIR__ . '../../Documents';
+        $classPath = __DIR__.'../../Documents';
         $config->setMetadataDriverImpl(AnnotationDriver::create($classPath));
 
         self::$dm = DocumentManager::create(new Connection(), $config);
 
         $documentName = 'Dtc\QueueBundle\Documents\Job';
         $sm = self::$dm->getSchemaManager();
-        $timeout  = 1000;
+        $timeout = 1000;
 
         $sm->dropDocumentCollection($documentName);
         $sm->createDocumentCollection($documentName);

Tests/Model/BaseJobManagerTest.php

Unused Use Statements -3 removed lines

@@ -2,9 +2,6 @@
 namespace Dtc\QueueBundle\Tests\Model;
 
 use Dtc\QueueBundle\Model\Job;
-use Dtc\QueueBundle\Tests\FibonacciWorker;
-use Dtc\QueueBundle\Tests\StaticJobManager;
-use Dtc\QueueBundle\Model\WorkerManager;
 
 class BaseJobManagerTest
     extends \PHPUnit_Framework_TestCase

Spacing +1 added lines, -1 removed lines

@@ -83,7 +83,7 @@
     public function testPerformance() {
         $start = microtime(true);
         $jobsTotal = 1000;
-        self::$jobManager->enableSorting = false;	// Ignore priority
+        self::$jobManager->enableSorting = false; // Ignore priority
 
         for ($i = 0; $i < $jobsTotal; $i++) {
             self::$worker->later()->fibonacci(1);