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

Tests/Model/WorkerTest.php

Doc Comments +5 added lines

@@ -104,6 +104,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/Job.php

Doc Comments +5 added lines, -5 removed lines

@@ -127,7 +127,7 @@ 
     }
 
     /**
-     * @return the $className
+     * @return string $className
      */
     public function getClassName()
     {
@@ -298,7 +298,7 @@ 
     }
 
     /**
-     * @param field_type $createdAt
+     * @param \DateTime $createdAt
      */
     public function setCreatedAt($createdAt)
     {
@@ -306,7 +306,7 @@ 
     }
 
     /**
-     * @param field_type $updatedAt
+     * @param \DateTime $updatedAt
      */
     public function setUpdatedAt($updatedAt)
     {
@@ -361,7 +361,7 @@ 
     }
 
     /**
-     * @return the $worker
+     * @return null|Worker $worker
      */
     public function getWorker()
     {
@@ -392,7 +392,7 @@ 
 	}
 
 	/**
-	 * @param field_type $elapsed
+	 * @param double $elapsed
 	 */
 	public function setElapsed($elapsed)
 	{

Model/Worker.php

Doc Comments +10 added lines

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