Слушатель

класс Слушатель (Просмотреть исходный код)

Свойства

protected string	$commandPath	Путь к исполняемой команде.
protected string	$environment	Среда, в которой должны выполняться рабочие процессы.
protected int	$sleep	Количество секунд, которое нужно ждать перед опросом очереди.
protected int	$maxTries	Количество попыток выполнения задачи перед записью о её неудаче.
protected Closure\|null	$outputHandler	Обработчик вывода.

Методы

void

__construct(string $commandPath)

Создать нового слушателя очереди.

string

phpBinary()

Получить интерпретатор PHP.

string

artisanBinary()

Получить утилиту Artisan.

void

listen(string $connection, string $queue, ListenerOptions $options)

Подключиться к указанной очереди.

Process

makeProcess(string $connection, string $queue, ListenerOptions $options)

Создать новый процесс Symfony для рабочего процесса.

array

addEnvironment(array $command, ListenerOptions $options)

Добавить опцию среды к заданной команде.

array

createCommand(string $connection, string $queue, ListenerOptions $options)

Создать команду с параметрами слушателя.

void

runProcess(Process $process, int $memory)

Выполнить заданный процесс.

void

handleWorkerOutput(int $type, string $line)

Обработать вывод от рабочего процесса.

bool

memoryExceeded(int $memoryLimit)

Определить, превышен ли лимит памяти.

void

stop()

Остановить прослушивание и выйти из скрипта.

void

setOutputHandler(Closure $outputHandler)

Установить обработчик вывода.

Детали

void __construct(string $commandPath)

Создать нового слушателя очереди.

Параметры

string

$commandPath

Возвращаемое значение

void

protected string phpBinary()

Получить интерпретатор PHP.

Возвращаемое значение

string

protected string artisanBinary()

Получить утилиту Artisan.

Возвращаемое значение

string

void listen(string $connection, string $queue, ListenerOptions $options)

Подключиться к указанной очереди.

Параметры

string	$connection
string	$queue
ListenerOptions	$options

Возвращаемое значение

void

Process makeProcess(string $connection, string $queue, ListenerOptions $options)

Создать новый процесс Symfony для рабочего процесса.

Параметры

string	$connection
string	$queue
ListenerOptions	$options

Возвращаемое значение

Process

protected array addEnvironment(array $command, ListenerOptions $options)

Добавить опцию среды к заданной команде.

Параметры

array	$command
ListenerOptions	$options

Возвращаемое значение

array

protected array createCommand(string $connection, string $queue, ListenerOptions $options)

Создать команду с параметрами слушателя.

Параметры

string	$connection
string	$queue
ListenerOptions	$options

Возвращаемое значение

array

void runProcess(Process $process, int $memory)

Выполнить заданный процесс.

Параметры

Process	$process
int	$memory

Возвращаемое значение

void

protected void handleWorkerOutput(int $type, string $line)

Обработать вывод от рабочего процесса.

Параметры

int	$type
string	$line

Возвращаемое значение

void

bool memoryExceeded(int $memoryLimit)

Определить, превышен ли лимит памяти.

Параметры

int

$memoryLimit

Возвращаемое значение

bool

void stop()

Остановить прослушивание и выйти из скрипта.

Возвращаемое значение

void

void setOutputHandler(Closure $outputHandler)

Установить обработчик вывода.

Параметры

Closure

$outputHandler

Возвращаемое значение

void

© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/8.x/Illuminate/Queue/Listener.html