* Add a delayed job to a transaction. */
(mixed $transaction, Job $job, int $delay)
| 148 | * Add a delayed job to a transaction. |
| 149 | */ |
| 150 | private function addDelayedJobToTransaction(mixed $transaction, Job $job, int $delay): void |
| 151 | { |
| 152 | $keys = $this->getKeys(['marker', 'meta', 'id', 'delayed', 'completed', 'events']); |
| 153 | $args = $this->addJobArgs($job); |
| 154 | $args[] = $job->timestamp + $delay; |
| 155 | |
| 156 | $this->execScriptOnTransaction($transaction, 'addDelayedJob-6.lua', $keys, $args); |
| 157 | } |
| 158 | |
| 159 | /** |
| 160 | * Add a prioritized job to a transaction. |
no test coverage detected