Слушатель

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

Свойства

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

Методы

void

__construct(string $commandPath)

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

string

buildCommandTemplate()

Сформировать шаблон команды для рабочего процесса, специфичный для среды.

string

phpBinary()

Получить бинарник PHP.

string

artisanBinary()

Получить бинарник Artisan.

void

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

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

Process

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

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

string

addEnvironment(string $command, ListenerOptions $options)

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

string

formatCommand(string $command, 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 buildCommandTemplate()

Сформировать шаблон команды для рабочего процесса, специфичный для среды.

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

string

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 string addEnvironment(string $command, ListenerOptions $options)

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

Параметры

string	$command
ListenerOptions	$options

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

string

protected string formatCommand(string $command, string $connection, string $queue, ListenerOptions $options)

Отформатировать заданную команду с параметрами слушателя.

Параметры

string	$command
string	$connection
string	$queue
ListenerOptions	$options

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

string

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