mmucklo / DtcQueueBundle

Tests/ORM/RunManagerTest.php

Spacing +2 added lines, -2 removed lines

@@ -64,7 +64,7 @@ 
             'doctrine.orm.default_entity_manager',
             $factory->createProxy(
                 EntityManager::class,
-                function (&$wrappedObject, $proxy, $method, $parameters, &$initializer) use ($objectManager) {
+                function(&$wrappedObject, $proxy, $method, $parameters, &$initializer) use ($objectManager) {
                     $wrappedObject = $objectManager;
                     $initializer = null;
                 }
@@ -92,7 +92,7 @@ 
             'doctrine.orm.default_entity_manager',
             $factory->createProxy(
                 EntityManager::class,
-                function (&$wrappedObject, $proxy, $method, $parameters, &$initializer) use ($objectManager) {
+                function(&$wrappedObject, $proxy, $method, $parameters, &$initializer) use ($objectManager) {
                     $wrappedObject = $objectManager;
                     $initializer = null;
                 }

ORM/JobManager.php

Doc Comments +1 added lines, -1 removed lines

@@ -212,7 +212,7 @@
      * @param bool   $prioritize
      * @param int    $runId
      *
-     * @return Job|null
+     * @return boolean|null
      */
     public function getJob($workerName = null, $methodName = null, $prioritize = true, $runId = null)
     {

Redis/StatusTrait.php

Doc Comments +3 added lines

@@ -6,6 +6,9 @@
 
 trait StatusTrait
 {
+    /**
+     * @param string $cacheKey
+     */
     protected function collateStatusResults(array &$results, $cacheKey)
     {
         $cursor = null;

Spacing +1 added lines, -1 removed lines

@@ -431,7 +431,7 @@
     {
         $cursor = null;
         while ($jobs = $this->redis->zScan($cacheKey, $cursor, '', 100)) {
-            $jobs = $this->redis->mget(array_map(function ($item) {
+            $jobs = $this->redis->mget(array_map(function($item) {
                 return $this->getJobCacheKey($item);
             }, array_keys($jobs)));
             $this->extractStatusResults($jobs, $results);