Слушатель

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

Свойства

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

Методы

void

__construct(строка $commandPath)

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

строка

buildWorkerCommand()

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

void

listen(строка $connection, строка $queue, строка $delay, строка $memory, целое число $timeout = 60)

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

void

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

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

Process

makeProcess(строка $connection, строка $queue, целое число $delay, целое число $memory, целое число $timeout)

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

void

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

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

логическое значение

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

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

void

stop()

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

void

setOutputHandler(Closure $outputHandler)

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

строка

getEnvironment()

Получить текущую среду слушателя.

void

setEnvironment(строка $environment)

Установить текущую среду.

целое число

getSleep()

Получить количество секунд ожидания перед опросом очереди.

void

setSleep(целое число $sleep)

Установить количество секунд ожидания перед опросом очереди.

void

setMaxTries(целое число $tries)

Установить количество попыток выполнения задачи перед записью о неудаче.

Подробности

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

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

Параметры

строка

$commandPath

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

void

protected строка buildWorkerCommand()

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

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

строка

void listen(строка $connection, строка $queue, строка $delay, строка $memory, целое число $timeout = 60)

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

Параметры

строка	$connection
строка	$queue
строка	$delay
строка	$memory
целое число	$timeout

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

void

void runProcess(Process $process, int $memory)

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

Параметры

Process	$process
int	$memory

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

void

Process makeProcess(string $connection, string $queue, int $delay, int $memory, int $timeout)

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

Параметры

string	$connection
string	$queue
int	$delay
int	$memory
int	$timeout

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

Process

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

string getEnvironment()

Получить текущую среду слушателя.

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

string

void setEnvironment(string $environment)

Установить текущую среду.

Параметры

string

$environment

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

void

int getSleep()

Получить количество секунд ожидания перед опросом очереди.

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

int

void setSleep(int $sleep)

Установить количество секунд ожидания перед опросом очереди.

Параметры

int

$sleep

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

void

void setMaxTries(int $tries)

Установить количество попыток выполнения задачи перед отменой ее как завершенной с ошибкой.

Параметры

int

$tries

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

void

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