Слушатель

класс Listener (Просмотр исходного кода)

Свойства

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)

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

never

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

never stop()

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

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

never

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