Слушатель

класс 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.6/Illuminate/Queue/Listener.html