Properties

$options

$options : 

Type

Methods

push()

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

Parameters

$job
$data
$queue

later()

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

Parameters

$delay
$job
$data
$queue

pop()

pop(  $queue = null) 

Parameters

$queue

marshal()

marshal() 

__construct()

__construct(array  $options) 

Parameters

array $options

release()

release(string  $queue, \StdClass  $job, integer  $delay) : mixed

重新发布任务

Parameters

string $queue
\StdClass $job
integer $delay

Returns

mixed

deleteReserved()

deleteReserved(string  $id) : void

删除任务

Parameters

string $id

createPayload()

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

Parameters

$job
$data
$queue

createPlainPayload()

createPlainPayload(  $job,   $data) 

Parameters

$job
$data

setMeta()

setMeta(  $payload,   $key,   $value) 

Parameters

$payload
$key
$value

pushToDatabase()

pushToDatabase(\DateTime|integer  $delay, string|null  $queue, string  $payload, integer  $attempts) : mixed

Push a raw payload to the database with a given delay.

Parameters

\DateTime|integer $delay
string|null $queue
string $payload
integer $attempts

Returns

mixed

getNextAvailableJob()

getNextAvailableJob(string|null  $queue) : \StdClass|null

获取下个有效任务

Parameters

string|null $queue

Returns

\StdClass|null

markJobAsReserved()

markJobAsReserved(string  $id) : void

标记任务正在执行.

Parameters

string $id

releaseJobsThatHaveBeenReservedTooLong()

releaseJobsThatHaveBeenReservedTooLong(string  $queue) : void

重新发布超时的任务

Parameters

string $queue

getQueue()

getQueue(  $queue) 

Parameters

$queue