\think\queue\connectorDatabase

Summary

Methods

Properties

Constants

push()
later()
pop()
marshal()
__construct()
release()
deleteReserved()

No public properties found

No constants found

createPayload()
createPlainPayload()
setMeta()
pushToDatabase()
getNextAvailableJob()
markJobAsReserved()
releaseJobsThatHaveBeenReservedTooLong()
getQueue()

$options

N/A

No private methods found

No private properties found

N/A

File: addons/queue/SDK/src/queue/connector/Database.php
Package: Application
Class hierarchy: Connector

\think\queue\connector\Database
Uses

Properties

$options

$options

Methods

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 —

pop()

pop(mixed  $queue = null) : mixed

Parameters

mixed

$queue

Returns

mixed —

marshal()

marshal() : mixed

Returns

mixed —

__construct()

__construct(array  $options) : mixed

Parameters

array

$options

Returns

mixed —

release()

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

重新发布任务

Parameters

string	$queue
\StdClass	$job
int	$delay

Returns

mixed —

deleteReserved()

deleteReserved(string  $id) : void

删除任务

Parameters

string

$id

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 —

pushToDatabase()

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

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

Parameters

\DateTime\|int	$delay
string\|null	$queue
string	$payload
int	$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(mixed  $queue) : mixed

Parameters

mixed

$queue

Returns

mixed —