\think\queue\driverRedis

__construct()

__construct(  $options) 

Parameters

push()

push(  $job,   $data = '',   $queue = null) 

Parameters

later()

later(  $delay,   $job,   $data = '',   $queue = null) 

Parameters

pop()

pop(  $queue = null) 

Parameters

release()

release(string  $queue, string  $payload, integer  $delay, integer  $attempts) : void

重新发布任务

Parameters

pushRaw()

pushRaw(  $payload,   $queue = null) 

Parameters

deleteReserved()

deleteReserved(string  $queue, string  $job) : void

删除任务

Parameters

migrateExpiredJobs()

migrateExpiredJobs(string  $from, string  $to, boolean  $attempt = true) 

移动延迟任务

Parameters

createPayload()

createPayload(  $job,   $data) 

Parameters

migrateAllExpiredJobs()

migrateAllExpiredJobs(string  $queue) : void

移动所有任务

Parameters

transaction()

transaction(\Closure  $closure) 

redis事务

Parameters

getExpiredJobs()

getExpiredJobs(string  $from, integer  $time) : array

获取所有到期任务

Parameters

Returns

removeExpiredJobs()

removeExpiredJobs(string  $from, integer  $time) : void

删除过期任务

Parameters

pushExpiredJobsOntoNewQueue()

pushExpiredJobsOntoNewQueue(string  $to, array  $jobs, boolean  $attempt = true) 

重新发布到期任务

Parameters

getRandomId()

getRandomId() : string

随机id

Returns

setMeta()

setMeta(  $payload,   $key,   $value) 

Parameters

getQueue()

getQueue(string|null  $queue) : string

获取队列名

Parameters

Returns