push() push(mixed $job, mixed $data = '', mixed $queue = null) : mixed Parameters mixed $job mixed $data mixed $queue Returns mixed —
later() later(mixed $delay, mixed $job, mixed $data = '', mixed $queue = null) : mixed Parameters mixed $delay mixed $job mixed $data mixed $queue Returns mixed —
release() release(string $queue, string $payload, int $delay, int $attempts) : void 重新发布任务 Parameters string $queue string $payload int $delay int $attempts
pushRaw() pushRaw(mixed $payload, mixed $queue = null) : mixed Parameters mixed $payload mixed $queue Returns mixed —
deleteReserved() deleteReserved(string $queue, string $job) : void 删除任务 Parameters string $queue string $job
migrateExpiredJobs() migrateExpiredJobs(string $from, string $to, bool $attempt = true) : mixed 移动延迟任务 Parameters string $from string $to bool $attempt Returns mixed —
createPayload() createPayload(mixed $job, mixed $data = '', mixed $queue = null) : mixed Parameters mixed $job mixed $data mixed $queue Returns mixed —
createPlainPayload() createPlainPayload(mixed $job, mixed $data) : mixed Parameters mixed $job mixed $data Returns mixed —
setMeta() setMeta(mixed $payload, mixed $key, mixed $value) : mixed Parameters mixed $payload mixed $key mixed $value Returns mixed —
transaction() transaction(\Closure $closure) : mixed redis事务 Parameters \Closure $closure Returns mixed —
getExpiredJobs() getExpiredJobs(string $from, int $time) : array 获取所有到期任务 Parameters string $from int $time Returns array —
removeExpiredJobs() removeExpiredJobs(string $from, int $time) : void 删除过期任务 Parameters string $from int $time
pushExpiredJobsOntoNewQueue() pushExpiredJobsOntoNewQueue(string $to, array $jobs, bool $attempt = true) : mixed 重新发布到期任务 Parameters string $to array $jobs bool $attempt Returns mixed —
getQueue() getQueue(string|null $queue) : string 获取队列名 Parameters string|null $queue Returns string —