mmucklo / DtcQueueBundle

BeanStalkd/JobManager.php

Braces +1 added lines, -2 removed lines

@@ -57,8 +57,7 @@
         if ($job->getStatus() === BaseJob::STATUS_SUCCESS) {
             $this->beanstalkd
                 ->delete($job);
-        }
-        else {
+        } else {
             $this->beanstalkd
                 ->bury($job);
         }

Documents/JobManager.php

Braces +1 added lines, -2 removed lines

@@ -179,8 +179,7 @@
 
         if ($prioritize) {
             $qb->sort('priority', 'asc');
-        }
-        else {
+        } else {
             $qb->sort('when', 'asc');
         }
 

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

Model/Job.php

Braces +1 added lines, -2 removed lines

@@ -259,8 +259,7 @@
             }
 
             return true;
-        }
-        else {
+        } else {
             return !is_object($args);
         }
     }

Model/Worker.php

Braces +1 added lines, -2 removed lines

@@ -45,8 +45,7 @@
         if ($time) {
             $dateTime = new \DateTime();
             $dateTime->setTimestamp($time);
-        }
-        else {
+        } else {
             $dateTime = null;
         }
 

Model/WorkerManager.php

Braces +1 added lines, -2 removed lines

@@ -73,8 +73,7 @@
 			// Job finshed successfuly... do we remove the job from database?
 			$job->setStatus(Job::STATUS_SUCCESS);
 			$job->setMessage(null);
-		}
-		catch (\Exception $e) {
+		} catch (\Exception $e) {
 			if ($this->logger) {
 				$this->logger->debug("Failed: {$job->getClassName()}->{$job->getMethod()}\n{$e->getMessage()}");
 			}

Spacing +2 added lines, -2 removed lines

@@ -51,7 +51,7 @@ 
 				$this->logger->debug("No job to run");
 			}
 
-			return;        // no job to run
+			return; // no job to run
 		}
 
 		return $this->runJob($job);
@@ -80,7 +80,7 @@ 
 			}
 
 			$job->setStatus(Job::STATUS_ERROR);
-			$job->setMessage($e->getMessage() . "\n" .$e->getTraceAsString());
+			$job->setMessage($e->getMessage()."\n".$e->getTraceAsString());
 		}
 
 		// save Job history

RabbitMQ/JobManager.php

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

Braces +1 added lines, -2 removed lines

@@ -57,8 +57,7 @@
         if ($job->getStatus() === BaseJob::STATUS_SUCCESS) {
             $this->beanstalkd
                 ->delete($job);
-        }
-        else {
+        } else {
             $this->beanstalkd
                 ->bury($job);
         }

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

Braces +11 added lines, -6 removed lines

@@ -20,12 +20,17 @@
 
     public function fibonacci($n)
     {
-        if($n == 0)
-            return 0; //F0
-        elseif ($n == 1)
-            return 1; //F1
-        else
-            return $this->fibonacci($n - 1) + $this->fibonacci($n - 2);
+        if($n == 0) {
+                    return 0;
+        }
+        //F0
+        elseif ($n == 1) {
+                    return 1;
+        }
+        //F1
+        else {
+                    return $this->fibonacci($n - 1) + $this->fibonacci($n - 2);
+        }
     }
 
     public function getName() {

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