mmucklo / DtcQueueBundle

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;

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) {

Command/RunCommand.php

Spacing +1 added lines, -1 removed lines

@@ -68,7 +68,7 @@
         set_time_limit($processTimeout); // Set an hour timeout
 
         if ($jobId = $input->getOption('job_id')) {
-            return $this->runJobById($jobId);   // Run a single job
+            return $this->runJobById($jobId); // Run a single job
         }
 
         try {

Beanstalkd/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) {

Model/Job.php

Doc Comments +6 added lines, -6 removed lines

@@ -44,7 +44,7 @@ 
     }
 
     /**
-     * @param $message
+     * @param string|null $message
      */
     public function setMessage($message)
     {
@@ -244,7 +244,7 @@ 
     }
 
     /**
-     * @return mixed
+     * @return \DateTime
      */
     public function getStartedAt()
     {
@@ -252,7 +252,7 @@ 
     }
 
     /**
-     * @param mixed $startedAt
+     * @param \DateTime $startedAt
      */
     public function setStartedAt(\DateTime $startedAt)
     {
@@ -268,7 +268,7 @@ 
     }
 
     /**
-     * @param mixed $finishedAt
+     * @param \DateTime $finishedAt
      */
     public function setFinishedAt($finishedAt)
     {
@@ -335,7 +335,7 @@ 
     }
 
     /**
-     * @param $crcHash
+     * @param string $crcHash
      */
     public function setCrcHash($crcHash)
     {
@@ -449,7 +449,7 @@ 
     }
 
     /**
-     * @param $elapsed
+     * @param double $elapsed
      */
     public function setElapsed($elapsed)
     {

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');

Model/WorkerManager.php

Spacing +2 added lines, -2 removed lines

@@ -63,7 +63,7 @@ 
                 $this->logger->debug('No job to run');
             }
 
-            return;        // no job to run
+            return; // no job to run
         }
 
         return $this->runJob($job);
@@ -75,7 +75,7 @@ 
         $this->eventDispatcher->dispatch(Event::PRE_JOB, $event);
 
         $start = microtime(true);
-        $handleException = function ($exception) use ($job) {
+        $handleException = function($exception) use ($job) {
             $exceptionMessage = get_class($exception)."\n".$exception->getCode().' - '.$exception->getMessage()."\n".$exception->getTraceAsString();
             if ($this->logger) {
                 $this->logger->debug("Failed: {$job->getClassName()}->{$job->getMethod()}\n$exceptionMessage");

Tests/Model/BaseJobManagerTest.php

Spacing +1 added lines, -1 removed lines

@@ -86,7 +86,7 @@
     {
         $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);