Слушатель

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

Свойства

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

Методы

void

__construct(строка $commandPath)

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

строка

phpBinary()

Получить путь к исполняемому файлу PHP.

строка

artisanBinary()

Получить путь к исполняемому файлу Artisan.

void

listen(строка $connection, строка $queue, ListenerOptions $options)

Прослушивать заданную очередь.

Process

makeProcess(строка $connection, строка $queue, ListenerOptions $options)

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

массив

addEnvironment(массив $command, ListenerOptions $options)

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

массив

createCommand(строка $connection, строка $queue, ListenerOptions $options)

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

void

runProcess(Process $process, целое число $memory)

Запустить данный процесс.

void

handleWorkerOutput(целое число $type, строка $line)

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

bool

memoryExceeded(целое число $memoryLimit)

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

void

stop()

Остановить прослушивание и прервать выполнение сценария.

void

setOutputHandler(Closure $outputHandler)

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

Подробности

void __construct(строка $commandPath)

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

Параметры

строка

$commandPath

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

void

protected строка phpBinary()

Получить путь к исполняемому файлу PHP.

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

строка

protected строка artisanBinary()

Получить путь к исполняемому файлу Artisan.

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

строка

END_OF_DOCUMENT_MARKER

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/7.x/Illuminate/Queue/Listener.html