mmucklo / DtcQueueBundle

ORM/JobManager.php

Doc Comments +4 added lines

@@ -120,6 +120,10 @@
     }
 
 
+    /**
+     * @param string $workerName
+     * @param string $method
+     */
     protected function addWorkerNameCriterion(QueryBuilder $queryBuilder, $workerName = null, $method = null)
     {
         if (null !== $workerName) {

Braces +2 added lines, -4 removed lines

@@ -99,8 +99,7 @@ 
 
         if ($function === 'save') {
             $compare = static::$resetInsertCalled;
-        }
-        else {
+        } else {
             $compare = static::$saveInsertCalled;
         }
 
@@ -113,8 +112,7 @@ 
 
         if ($function === 'save') {
             static::$saveInsertCalled = spl_object_hash($objectManager);
-        }
-        else {
+        } else {
             static::$resetInsertCalled = spl_object_hash($objectManager);
         }
     }

Doctrine/BaseJobManager.php

Braces +1 added lines, -2 removed lines

@@ -240,8 +240,7 @@
                 if ($this->updateMaxStatus($job, RetryableJob::STATUS_MAX_STALLED, $job->getMaxStalled(), $job->getStalledCount())) {
                     $objectManager->remove($job);
                     continue;
-                }
-                else if ($this->updateMaxStatus($job, RetryableJob::STATUS_MAX_RETRIES, $job->getMaxRetries(), $job->getRetries())) {
+                } else if ($this->updateMaxStatus($job, RetryableJob::STATUS_MAX_RETRIES, $job->getMaxRetries(), $job->getRetries())) {
                     $objectManager->remove($job);
                     continue;
                 }