Слушатель

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

Свойства

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

Методы

void

__construct(string $commandPath)

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

string

buildWorkerCommand()

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

void

listen(string $connection, string $queue, string $delay, string $memory, int $timeout = 60)

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

void

runProcess(Process $process, int $memory)

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

Process

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

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

void

handleWorkerOutput(int $type, string $line)

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

bool

memoryExceeded(int $memoryLimit)

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

void

stop()

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

void

setOutputHandler(Closure $outputHandler)

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

string

getEnvironment()

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

void

setEnvironment(string $environment)

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

int

getSleep()

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

void

setSleep(int $sleep)

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

void

setMaxTries(int $tries)

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

Подробное описание

void __construct(string $commandPath)

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

Параметры

string

$commandPath

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

void

protected string buildWorkerCommand()

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

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

string

void listen(string $connection, string $queue, string $delay, string $memory, int $timeout = 60)

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

Параметры

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

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

void

END_OF_DOCUMENT_MARKER

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