class QueueRunner extends BaseRunner implements TaskRunnerEngine (View source)

Runs all jobs in a queue loop in one process

Methods

public
getService()

Returns an instance of the QueuedJobService.

protected
writeLogLine(string $line, null|string $prefix = null)

Write in a format expected by the output medium (CLI/HTML).

protected
logDescriptorStatus(bool|null|QueuedJobDescriptor $descriptor, string $queue)

Logs the status of the queued job descriptor.

public
listJobs()

Logs the number of current jobs per queue

public
runQueue(string $queue)

No description

Details

QueuedJobService getService()

Returns an instance of the QueuedJobService.

Return Value

QueuedJobService

protected writeLogLine(string $line, null|string $prefix = null)

Write in a format expected by the output medium (CLI/HTML).

Parameters

string $line

Line to be written out, without the newline character.

null|string $prefix

protected logDescriptorStatus(bool|null|QueuedJobDescriptor $descriptor, string $queue)

Logs the status of the queued job descriptor.

Parameters

bool|null|QueuedJobDescriptor $descriptor
string $queue

listJobs()

Logs the number of current jobs per queue

runQueue(string $queue)

No description

Parameters

string $queue