mmucklo /
DtcQueueBundle
| @@ 57-77 (lines=21) @@ | ||
| 54 | return $count; |
|
| 55 | } |
|
| 56 | ||
| 57 | public function pruneErroneousJobs($workerName = null, $method = null) |
|
| 58 | { |
|
| 59 | /** @var EntityManager $objectManager */ |
|
| 60 | $objectManager = $this->getObjectManager(); |
|
| 61 | $qb = $objectManager->createQueryBuilder()->delete($this->getArchiveObjectName(), 'j'); |
|
| 62 | $qb = $qb |
|
| 63 | ->where('j.status = :status') |
|
| 64 | ->setParameter(':status', Job::STATUS_ERROR); |
|
| 65 | ||
| 66 | if ($workerName) { |
|
| 67 | $qb->andWhere('j.workerName = :workerName')->setParameter(':workerName', $workerName); |
|
| 68 | } |
|
| 69 | ||
| 70 | if ($method) { |
|
| 71 | $qb->andWhere('j.method = :method')->setParameter(':method', $method); |
|
| 72 | } |
|
| 73 | ||
| 74 | $query = $qb->getQuery(); |
|
| 75 | ||
| 76 | return $query->execute(); |
|
| 77 | } |
|
| 78 | ||
| 79 | public function pruneExpiredJobs($workerName = null, $method = null) |
|
| 80 | { |
|
| @@ 79-99 (lines=21) @@ | ||
| 76 | return $query->execute(); |
|
| 77 | } |
|
| 78 | ||
| 79 | public function pruneExpiredJobs($workerName = null, $method = null) |
|
| 80 | { |
|
| 81 | /** @var EntityManager $objectManager */ |
|
| 82 | $objectManager = $this->getObjectManager(); |
|
| 83 | $qb = $objectManager->createQueryBuilder()->delete($this->getObjectName(), 'j'); |
|
| 84 | $qb = $qb |
|
| 85 | ->where('j.expiresAt <= :expiresAt') |
|
| 86 | ->setParameter(':expiresAt', new \DateTime()); |
|
| 87 | ||
| 88 | if ($workerName) { |
|
| 89 | $qb->andWhere('j.workerName = :workerName')->setParameter(':workerName', $workerName); |
|
| 90 | } |
|
| 91 | ||
| 92 | if ($method) { |
|
| 93 | $qb->andWhere('j.method = :method')->setParameter(':method', $method); |
|
| 94 | } |
|
| 95 | ||
| 96 | $query = $qb->getQuery(); |
|
| 97 | ||
| 98 | return $query->execute(); |
|
| 99 | } |
|
| 100 | ||
| 101 | /** |
|
| 102 | * Removes archived jobs older than $olderThan. |
|
