PlatformQueuesRunCommand
extends Command
in package
Runs every application queue lane from one background worker authority.
Table of Contents
Properties
Methods
- __construct() : mixed
- defaultName() : string
- execute() : int
- buildOptionParser() : ConsoleOptionParser
- getPlatformJobRunner() : PlatformJobRunner
- getQueueDrainService() : PlatformQueueDrainService
Properties
$platformJobRunner read-only
private
PlatformJobRunner|null
$platformJobRunner
= null
$queueDrainService read-only
private
PlatformQueueDrainService|null
$queueDrainService
= null
Methods
__construct()
public
__construct([PlatformQueueDrainService|null $queueDrainService = null ][, PlatformJobRunner|null $platformJobRunner = null ]) : mixed
Parameters
- $queueDrainService : PlatformQueueDrainService|null = null
-
Queue fleet processor
- $platformJobRunner : PlatformJobRunner|null = null
-
Platform job processor
defaultName()
public
static defaultName() : string
Tags
Return values
stringexecute()
public
execute(Arguments $args, ConsoleIo $io) : int
Parameters
- $args : Arguments
- $io : ConsoleIo
Tags
Return values
intbuildOptionParser()
protected
buildOptionParser(ConsoleOptionParser $parser) : ConsoleOptionParser
Parameters
- $parser : ConsoleOptionParser
Tags
Return values
ConsoleOptionParsergetPlatformJobRunner()
private
getPlatformJobRunner() : PlatformJobRunner
Return values
PlatformJobRunnergetQueueDrainService()
private
getQueueDrainService() : PlatformQueueDrainService