Слушатель

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

Свойства

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

Методы

void

__construct(string $commandPath)

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

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

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

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

Параметры

string	$connection
string	$queue
string	$delay
string	$memory
int	$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/4.2/Illuminate/Queue/Listener.html