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

$options
$db

N/A

No private methods found

No private properties found

N/A

File: s1/vendor/topthink/think-queue/src/queue/connector/Database.php
Package: Default
Class hierarchy: \think\queue\Connector

\think\queue\connector\Database

Properties

$options

$options :

Type

$db

$db :

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(  $options)

Parameters

$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