* Add a job to a transaction (for bulk operations). * * @param mixed $transaction The Predis transaction * @param Job $job * @return void */
(mixed $transaction, Job $job)
| 122 | * @return void |
| 123 | */ |
| 124 | public function addJobToTransaction(mixed $transaction, Job $job): void |
| 125 | { |
| 126 | if ($job->opts->delay > 0) { |
| 127 | $this->addDelayedJobToTransaction($transaction, $job, $job->opts->delay); |
| 128 | } elseif ($job->opts->priority !== null && $job->opts->priority > 0) { |
| 129 | $this->addPrioritizedJobToTransaction($transaction, $job, $job->opts->priority); |
| 130 | } else { |
| 131 | $this->addStandardJobToTransaction($transaction, $job, $job->timestamp); |
| 132 | } |
| 133 | } |
| 134 | |
| 135 | /** |
| 136 | * Add a standard job to a transaction. |
no test coverage detected