mmucklo / DtcQueueBundle

ODM/JobManager.php

Doc Comments +4 added lines, -3 removed lines

@@ -59,9 +59,10 @@
     /**
      * Prunes jobs according to a condition function.
      *
-     * @param null $workerName
-     * @param null $method
-     * @param $conditionFunc
+     * @param string|null $workerName
+     * @param string|null $method
+     * @param \Closure $conditionFunc
+     * @param string $objectName
      *
      * @return int
      */

Spacing +2 added lines, -2 removed lines

@@ -50,7 +50,7 @@ 
      */
     public function pruneErroneousJobs($workerName = null, $method = null)
     {
-        return $this->pruneJobs($workerName, $method, $this->getArchiveObjectName(), function ($qb) {
+        return $this->pruneJobs($workerName, $method, $this->getArchiveObjectName(), function($qb) {
             /* @var Builder $qb */
             return $qb->field('status')->equals(Job::STATUS_ERROR);
         });
@@ -98,7 +98,7 @@ 
      */
     public function pruneExpiredJobs($workerName = null, $method = null)
     {
-        return $this->pruneJobs($workerName, $method, $this->getObjectName(), function ($qb) {
+        return $this->pruneJobs($workerName, $method, $this->getObjectName(), function($qb) {
             /* @var Builder $qb */
             return $qb->field('expiresAt')->lte(new \DateTime());
         });

ORM/JobManager.php

Doc Comments +4 added lines, -3 removed lines

@@ -72,9 +72,10 @@
     /**
      * Prunes jobs according to a condition function.
      *
-     * @param null $workerName
-     * @param null $method
-     * @param $conditionFunc
+     * @param string|null $workerName
+     * @param string|null $method
+     * @param \Closure $conditionFunc
+     * @param string $objectName
      *
      * @return int Count of jobs pruned
      */

Spacing +2 added lines, -2 removed lines

@@ -62,7 +62,7 @@ 
      */
     public function pruneErroneousJobs($workerName = null, $method = null)
     {
-        return $this->pruneJobs($workerName, $method, $this->getArchiveObjectName(), function ($qb) {
+        return $this->pruneJobs($workerName, $method, $this->getArchiveObjectName(), function($qb) {
             /* @var QueryBuilder $qb */
             $qb->where('j.status = :status')
                 ->setParameter(':status', Job::STATUS_ERROR);
@@ -106,7 +106,7 @@ 
      */
     public function pruneExpiredJobs($workerName = null, $method = null)
     {
-        return $this->pruneJobs($workerName, $method, $this->getObjectName(), function ($qb) {
+        return $this->pruneJobs($workerName, $method, $this->getObjectName(), function($qb) {
             /* @var QueryBuilder $qb */
             $qb->where('j.expiresAt <= :expiresAt')
                 ->setParameter(':expiresAt', new \DateTime());