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

DependencyInjection/DtcQueueExtension.php

Indentation +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
 {
     public function load(array $configs, ContainerBuilder $container)
     {
-    	$documentName = 'Dtc\QueueBundle\Documents\Job';
+        $documentName = 'Dtc\QueueBundle\Documents\Job';
         $processor = new Processor();
         $configuration = new Configuration();
 

DtcQueueBundle.php

Indentation +1 added lines, -1 removed lines

@@ -7,7 +7,7 @@
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 
 class DtcQueueBundle
-	extends Bundle
+    extends Bundle
 {
     public function build(ContainerBuilder $container)
     {

Model/Job.php

Indentation +15 added lines, -15 removed lines

@@ -383,19 +383,19 @@
     {
         $this->worker = $worker;
     }
-	/**
-	 * @return the $elapsed
-	 */
-	public function getElapsed()
-	{
-		return $this->elapsed;
-	}
-
-	/**
-	 * @param field_type $elapsed
-	 */
-	public function setElapsed($elapsed)
-	{
-		$this->elapsed = $elapsed;
-	}
+    /**
+     * @return the $elapsed
+     */
+    public function getElapsed()
+    {
+        return $this->elapsed;
+    }
+
+    /**
+     * @param field_type $elapsed
+     */
+    public function setElapsed($elapsed)
+    {
+        $this->elapsed = $elapsed;
+    }
 }

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/WorkerManager.php

Indentation +72 added lines, -72 removed lines

@@ -7,94 +7,94 @@
 
 class WorkerManager
 {
-	protected $workers;
-	protected $jobManager;
-	protected $logger;
+    protected $workers;
+    protected $jobManager;
+    protected $logger;
     protected $eventDispatcher;
 
-	public function __construct(JobManagerInterface $jobManager, EventDispatcher $eventDispatcher, Logger $logger = null) {
-		$this->workers = array();
-		$this->jobManager = $jobManager;
-		$this->logger = $logger;
+    public function __construct(JobManagerInterface $jobManager, EventDispatcher $eventDispatcher, Logger $logger = null) {
+        $this->workers = array();
+        $this->jobManager = $jobManager;
+        $this->logger = $logger;
         $this->eventDispatcher = $eventDispatcher;
-	}
+    }
 
-	public function addWorker(Worker $worker) {
-		if ($this->logger) {
-			$this->logger->debug("Added worker: {$worker->getName()}");
-		}
+    public function addWorker(Worker $worker) {
+        if ($this->logger) {
+            $this->logger->debug("Added worker: {$worker->getName()}");
+        }
 
-		if (isset($this->workers[$worker->getName()])) {
-			throw new \Exception("{$worker->getName()} already exists in worker manager");
-		}
+        if (isset($this->workers[$worker->getName()])) {
+            throw new \Exception("{$worker->getName()} already exists in worker manager");
+        }
 
-		$this->workers[$worker->getName()] = $worker;
-	}
+        $this->workers[$worker->getName()] = $worker;
+    }
 
-	public function getWorker($name) {
-		if (isset($this->workers[$name])) {
-			return $this->workers[$name];
-		}
+    public function getWorker($name) {
+        if (isset($this->workers[$name])) {
+            return $this->workers[$name];
+        }
 
-		return null;
-	}
+        return null;
+    }
 
-	public function getWorkers() {
-		return $this->workers;
-	}
+    public function getWorkers() {
+        return $this->workers;
+    }
 
-	public function run($workerName = null, $methodName = null, $prioritize = true)
-	{
-		$job = $this->jobManager->getJob($workerName, $methodName, $prioritize);
-		if (!$job) {
-			if ($this->logger) {
-				$this->logger->debug("No job to run");
-			}
+    public function run($workerName = null, $methodName = null, $prioritize = true)
+    {
+        $job = $this->jobManager->getJob($workerName, $methodName, $prioritize);
+        if (!$job) {
+            if ($this->logger) {
+                $this->logger->debug("No job to run");
+            }
 
-			return;        // no job to run
-		}
+            return;        // no job to run
+        }
 
-		return $this->runJob($job);
-	}
+        return $this->runJob($job);
+    }
 
-	public function runJob(Job $job) {
+    public function runJob(Job $job) {
         $event = new Event($job);
         $this->eventDispatcher->dispatch(Event::PRE_JOB, $event);
 
-		try {
-			$start = microtime(true);
-			$worker = $this->getWorker($job->getWorkerName());
-			if ($this->logger) {
-				$this->logger->debug("Start: {$job->getClassName()}->{$job->getMethod()}", $job->getArgs());
-			}
-
-			call_user_func_array(array($worker, $job->getMethod()), $job->getArgs());
-
-			// Job finshed successfuly... do we remove the job from database?
-			$job->setStatus(Job::STATUS_SUCCESS);
-			$job->setMessage(null);
-		}
-		catch (\Exception $e) {
-			if ($this->logger) {
-				$this->logger->debug("Failed: {$job->getClassName()}->{$job->getMethod()}\n{$e->getMessage()}");
-			}
-
-			$job->setStatus(Job::STATUS_ERROR);
-			$job->setMessage($e->getMessage() . "\n" .$e->getTraceAsString());
-		}
-
-		// save Job history
-		$elapsed = microtime(true) - $start;
-		$job->setElapsed($elapsed);
-
-		if ($this->logger) {
-			$this->logger->debug("Finished: {$job->getClassName()}->{$job->getMethod()} in {$elapsed} micro-seconds");
-			$this->logger->debug("Save job history: {$job->getId()}");
-		}
-
-		$this->jobManager->saveHistory($job);
+        try {
+            $start = microtime(true);
+            $worker = $this->getWorker($job->getWorkerName());
+            if ($this->logger) {
+                $this->logger->debug("Start: {$job->getClassName()}->{$job->getMethod()}", $job->getArgs());
+            }
+
+            call_user_func_array(array($worker, $job->getMethod()), $job->getArgs());
+
+            // Job finshed successfuly... do we remove the job from database?
+            $job->setStatus(Job::STATUS_SUCCESS);
+            $job->setMessage(null);
+        }
+        catch (\Exception $e) {
+            if ($this->logger) {
+                $this->logger->debug("Failed: {$job->getClassName()}->{$job->getMethod()}\n{$e->getMessage()}");
+            }
+
+            $job->setStatus(Job::STATUS_ERROR);
+            $job->setMessage($e->getMessage() . "\n" .$e->getTraceAsString());
+        }
+
+        // save Job history
+        $elapsed = microtime(true) - $start;
+        $job->setElapsed($elapsed);
+
+        if ($this->logger) {
+            $this->logger->debug("Finished: {$job->getClassName()}->{$job->getMethod()} in {$elapsed} micro-seconds");
+            $this->logger->debug("Save job history: {$job->getId()}");
+        }
+
+        $this->jobManager->saveHistory($job);
         $this->eventDispatcher->dispatch(Event::POST_JOB, $event);
 
-		return $job;
-	}
+        return $job;
+    }
 }

Tests/Model/WorkerManagerTest.php

Indentation +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
         $this->jobManager = new StaticJobManager();
         $this->worker = new FibonacciWorker();
         $this->worker->setJobManager($this->jobManager);
-	$this->eventDispatcher = new EventDispatcher();
+    $this->eventDispatcher = new EventDispatcher();
         $this->workerManager = new WorkerManager($this->jobManager, $this->eventDispatcher);
     }
 

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