mmucklo / DtcQueueBundle

Tests/Model/WorkerTest.php

Doc Comments +5 added lines

@@ -108,6 +108,11 @@
         }
     }
 
+    /**
+     * @param integer|null $time
+     * @param string $method
+     * @param integer $priority
+     */
     protected function assertJob(Job $job, $time, $method, $priority = null)
     {
         $this->assertNotEmpty($job->getId(), 'Job should have an id');

DependencyInjection/Configuration.php

Indentation +2 added lines, -2 removed lines

@@ -31,8 +31,8 @@
                 ->end()
                 ->arrayNode('beanstalkd')
                     ->children()
-                       ->scalarNode('host')->end()
-                       ->scalarNode('tube')->end()
+                        ->scalarNode('host')->end()
+                        ->scalarNode('tube')->end()
                     ->end()
                 ->end()
                 ->arrayNode('rabbit_mq')

Command/PruneCommand.php

Doc Comments +1 added lines, -1 removed lines

@@ -64,7 +64,7 @@
     }
 
     /**
-     * @param array           $matches
+     * @param string[]           $matches
      * @param OutputInterface $output
      *
      * @return int

Command/RunCommand.php

Doc Comments +16 added lines

@@ -83,6 +83,9 @@ 
             ->setDescription('Start up a job in queue');
     }
 
+    /**
+     * @param double $start
+     */
     protected function runJobById($start, $jobId)
     {
         $this->runStart($start);
@@ -106,6 +109,10 @@ 
         return;
     }
 
+    /**
+     * @param string $varName
+     * @param integer $pow
+     */
     private function validateIntNull($varName, $var, $pow)
     {
         if (null === $var) {
@@ -122,6 +129,9 @@ 
         return intval($var);
     }
 
+    /**
+     * @param string $level
+     */
     public function log($level, $msg, array $context = [])
     {
         if ($this->logger) {
@@ -178,6 +188,12 @@ 
         return $this->runLoop($start, $workerName, $methodName, $nanoSleep, $maxCount, $duration);
     }
 
+    /**
+     * @param double $start
+     * @param null|integer $nanoSleep
+     * @param null|integer $maxCount
+     * @param null|integer $duration
+     */
     protected function runLoop($start, $workerName, $methodName, $nanoSleep, $maxCount, $duration)
     {
         $container = $this->getContainer();

Spacing +1 added lines, -1 removed lines

@@ -172,7 +172,7 @@
         set_time_limit($processTimeout); // Set timeout on the process
 
         if ($jobId = $input->getOption('id')) {
-            return $this->runJobById($start, $jobId);   // Run a single job
+            return $this->runJobById($start, $jobId); // Run a single job
         }
 
         return $this->runLoop($start, $workerName, $methodName, $nanoSleep, $maxCount, $duration);

Doctrine/BaseJobManager.php

Doc Comments +20 added lines

@@ -22,6 +22,12 @@ 
     protected $runClass;
     protected $runArchiveClass;
 
+    /**
+     * @param string $objectName
+     * @param string $archiveObjectName
+     * @param string $runClass
+     * @param string $runArchiveClass
+     */
     public function __construct(ObjectManager $objectManager,
         $objectName,
         $archiveObjectName,
@@ -83,6 +89,9 @@ 
         return $this->getObjectManager()->getRepository($this->getObjectName());
     }
 
+    /**
+     * @param string $objectName
+     */
     abstract protected function countJobsByStatus($objectName, $status, $workerName = null, $method = null);
 
     public function resetErroneousJobs($workerName = null, $method = null)
@@ -181,6 +190,10 @@ 
         return $countProcessed;
     }
 
+    /**
+     * @param string $workerName
+     * @param string $method
+     */
     public function pruneStalledJobs($workerName = null, $method = null)
     {
         $stalledJobs = $this->getStalledJobs($workerName, $method);
@@ -246,8 +259,15 @@ 
         return $job;
     }
 
+    /**
+     * @param string $objectName
+     */
     abstract protected function stopIdGenerator($objectName);
 
+    /**
+     * @param integer $limit
+     * @param integer $offset
+     */
     private function resetJobsByCriterion(
         $criterion,
         $limit,

Spacing +2 added lines, -2 removed lines

@@ -166,7 +166,7 @@ 
 
         $countProcessed = 0;
         for ($i = 0, $count = count($stalledJobs); $i < $count; $i += static::FETCH_COUNT) {
-            for ($j = $i, $max = $i + static::FETCH_COUNT; $j < $max && $j < $count; ++$j ) {
+            for ($j = $i, $max = $i + static::FETCH_COUNT; $j < $max && $j < $count; ++$j) {
                 $job = $stalledJobs[$j];
                 /* Job $job */
                 $job->setStatus(Job::STATUS_NEW);
@@ -188,7 +188,7 @@ 
 
         $countProcessed = 0;
         for ($i = 0, $count = count($stalledJobs); $i < $count; $i += static::FETCH_COUNT) {
-            for ($j = $i, $max = $i + static::FETCH_COUNT; $j < $max && $j < $count; ++$j ) {
+            for ($j = $i, $max = $i + static::FETCH_COUNT; $j < $max && $j < $count; ++$j) {
                 $job = $stalledJobs[$j];
                 $objectManager->remove($job);
                 ++$countProcessed;

ODM/JobManager.php

Doc Comments +10 added lines

@@ -31,6 +31,9 @@ 
         return $query->count();
     }
 
+    /**
+     * @param string $objectName
+     */
     public function stopIdGenerator($objectName)
     {
         $objectManager = $this->getObjectManager();
@@ -40,6 +43,10 @@ 
         $metadata->setIdGeneratorType(ClassMetadata::GENERATOR_TYPE_NONE);
     }
 
+    /**
+     * @param string $workerName
+     * @param string $method
+     */
     public function pruneErroneousJobs($workerName = null, $method = null)
     {
         /** @var DocumentManager $objectManager */
@@ -67,6 +74,8 @@ 
 
     /**
      * Prunes expired jobs.
+     * @param string $workerName
+     * @param string $method
      */
     public function pruneExpiredJobs($workerName = null, $method = null)
     {
@@ -148,6 +157,7 @@ 
 
     /**
      * Get Status Jobs.
+     * @param string $documentName
      */
     protected function getStatusByDocument($documentName)
     {

ORM/JobManager.php

Doc Comments +12 added lines, -1 removed lines

@@ -54,6 +54,10 @@ 
         return $count;
     }
 
+    /**
+     * @param string $workerName
+     * @param string $method
+     */
     public function pruneErroneousJobs($workerName = null, $method = null)
     {
         /** @var EntityManager $objectManager */
@@ -76,6 +80,10 @@ 
         return $query->execute();
     }
 
+    /**
+     * @param string $workerName
+     * @param string $method
+     */
     public function pruneExpiredJobs($workerName = null, $method = null)
     {
         /** @var EntityManager $objectManager */
@@ -181,6 +189,9 @@ 
         return $finalResult;
     }
 
+    /**
+     * @param string $entityName
+     */
     protected function getStatusByEntityName($entityName, array &$result)
     {
         /** @var EntityManager $objectManager */
@@ -207,7 +218,7 @@ 
      * @param string $methodName
      * @param bool   $prioritize
      *
-     * @return \Dtc\QueueBundle\Model\Job|null
+     * @return Job|null
      */
     public function getJob($workerName = null, $methodName = null, $prioritize = true, $runId = null)
     {

Indentation +1 added lines, -1 removed lines

@@ -130,7 +130,7 @@
             if ($method) {
                 $qb->where($qb->expr()->andX(
                     $qb->expr()->eq('j.workerName', ':workerName'),
-                                             $qb->expr()->eq('j.method', ':method')
+                                                $qb->expr()->eq('j.method', ':method')
                 ))
                     ->setParameter(':method', $method);
             } else {

RabbitMQ/JobManager.php

Doc Comments +18 added lines

@@ -29,11 +29,26 @@ 
         $this->pid = getmypid();
     }
 
+    /**
+     * @param string $exchange
+     * @param string $type
+     * @param boolean $passive
+     * @param boolean $durable
+     * @param boolean $autoDelete
+     */
     public function setExchangeArgs($exchange, $type, $passive, $durable, $autoDelete)
     {
         $this->exchangeArgs = func_get_args();
     }
 
+    /**
+     * @param string $queue
+     * @param boolean $passive
+     * @param boolean $durable
+     * @param boolean $exclusive
+     * @param boolean $autoDelete
+     * @param integer $maxPriority
+     */
     public function setQueueArgs($queue, $passive, $durable, $exclusive, $autoDelete, $maxPriority)
     {
         $arguments = func_get_args();
@@ -106,6 +121,9 @@ 
         return $job;
     }
 
+    /**
+     * @param string $workerName
+     */
     public function getJob($workerName = null, $methodName = null, $prioritize = true, $runId = null)
     {
         if ($methodName) {

Tests/Model/BaseJobManagerTest.php

Doc Comments +3 added lines

@@ -136,6 +136,9 @@
         }
     }
 
+    /**
+     * @param string $method
+     */
     protected function expectingException($method)
     {
         try {

Spacing +1 added lines, -1 removed lines

@@ -156,7 +156,7 @@
 
         $start = microtime(true);
         $jobsTotal = 100; // have to trim this down as Travis is slow.
-        self::$jobManager->enableSorting = false;    // Ignore priority
+        self::$jobManager->enableSorting = false; // Ignore priority
 
         for ($i = 0; $i < $jobsTotal; ++$i) {
             $startLater = microtime(true);