\DevOwl\RealQueue\queueQuery

getPluginConstantPrefix()

getPluginConstantPrefix(): string

Get the prefix of this package so we can utils package natively.

Returns

setupConstants()

setupConstants()

Make sure the REAL_QUEUE constants are available.

__construct()

__construct(\DevOwl\RealQueue\Core  $core)

C'tor.

Parameters

read()

read(array  $args = array()): array<mixed,\DevOwl\RealQueue\queue\Job>

Read jobs and cast them to proper `Job` instance.

Arguments:

• [limit]
• [type=all|pending|failure]
• [jobType]
• [dataContains] Allows you in a very basic way to check if a job exists by data LIKE '%YOUR_STRING%'
• [ids] An array of Job ids which should be read
• [omitClientData=false] If true, data will be omitted for server workers
• [after] Read all job ids after that one
• [lockUntil=0] Add this seconds to UNIX-timestamp and mark the read jobs as locked_until

Parameters

Returns

fetchById()

fetchById(integer  $id): \DevOwl\RealQueue\queue\Job|null

Fetch a single job by ID.

Parameters

Returns

readRemaining()

readRemaining()

Read remaining jobs per type. This does not count failed jobs! The result is an associative array:

[type: string]: [remaining: number, total: number, failure: number]

readCurrentJobs()

readCurrentJobs(boolean  $omitClientData = false)

Read current jobs per type.

Parameters

lockUntil()

lockUntil(array<mixed,integer>  $ids,integer  $seconds)

Lock a set of jobs by a given time of seconds.

Parameters

castRows()

castRows(array  $rows)

Cast read jobs to `Job` instance.

Parameters