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;

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

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

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

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

EventDispatcher/EventDispatcher.php

Spacing +2 added lines, -2 removed lines

@@ -15,7 +15,7 @@ 
 
     public function hasListeners($eventName)
     {
-        if ( ! isset($this->listeners[$eventName])) {
+        if (!isset($this->listeners[$eventName])) {
             return false;
         }
 
@@ -24,7 +24,7 @@ 
 
     public function dispatch($eventName, Event $event)
     {
-        if ( ! isset($this->listeners[$eventName])) {
+        if (!isset($this->listeners[$eventName])) {
             return;
         }
 

Tests/FibonacciWorker.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
 
     public function fibonacci($n)
     {
-        if($n == 0)
+        if ($n == 0)
             return 0; //F0
         elseif ($n == 1)
             return 1; //F1

Tests/Model/BaseJobManagerTest.php

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

Tests/Model/JobTest.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
         $worker = new FibonacciWorker();
         $job = new Job($worker, false, null);
         $job->setArgs(array(1));
-        $job->setArgs(array(1, array(1,2)));
+        $job->setArgs(array(1, array(1, 2)));
 
         try {
             $job->setArgs(array($job));

Tests/StaticJobManager.php

Spacing +1 added lines, -1 removed lines

@@ -65,7 +65,7 @@
     public function save($job) {
         if (!$job->getId()) {
             $job->setId($this->uniqeId);
-            $this->jobs[$job->getWorkerName()][$this->uniqeId]  = $job;
+            $this->jobs[$job->getWorkerName()][$this->uniqeId] = $job;
             if ($this->enableSorting) {
                 uasort($this->jobs[$job->getWorkerName()], array($this, 'compareJobPriority'));
             }