Слушатель
класс Listener (Просмотреть исходный код)
Свойства
| защищенная строка | $commandPath | Путь к исполняемой команде. | |
| защищенная строка | $environment | Окружение, в котором должны работать рабочие процессы. | |
| защищенное целое число | $sleep | Количество секунд ожидания перед опросом очереди. | |
| защищенное целое число | $maxTries | Количество попыток выполнения задачи перед записью о неудаче в журнал. | |
| защищенная Closure|null | $outputHandler | Обработчик вывода. |
Методы
| void | __construct(строка $commandPath) Создает нового слушателя очереди. | |
| строка | phpBinary() Получить исполняемый файл PHP. | |
| строка | artisanBinary() Получить исполняемый файл Artisan. | |
| void | listen(строка $connection, строка $queue, ListenerOptions $options) Прослушивать заданное соединение с очередью. | |
| Process | makeProcess(строка $connection, строка $queue, ListenerOptions $options) Создать новый процесс Symfony для рабочего процесса. | |
| массив | addEnvironment(массив $command, ListenerOptions $options) Добавить параметр среды к данной команде. | |
| массив | createCommand(строка $connection, строка $queue, ListenerOptions $options) Создать команду с параметрами слушателя. | |
| void | runProcess(Process $process, целое число $memory) Запустить данный процесс. | |
| void | handleWorkerOutput(целое число $type, строка $line) Обработать вывод от процесса рабочего процесса. | |
| логический тип | memoryExceeded(целое число $memoryLimit) Определить, превышен ли лимит памяти. | |
| void | stop() Остановить прослушивание и прервать выполнение скрипта. | |
| void | setOutputHandler(Closure $outputHandler) Установить обратный вызов обработчика вывода. |
Подробности
void __construct(строка $commandPath)
Создает нового слушателя очереди.
protected строка phpBinary()
Получить исполняемый файл PHP.
protected строка artisanBinary()
Получить исполняемый файл Artisan.
void listen(строка $connection, строка $queue, ListenerOptions $options)
Прослушивать заданное соединение с очередью.
Process makeProcess(строка $connection, строка $queue, ListenerOptions $options)
Создать новый процесс Symfony для рабочего процесса.
protected массив addEnvironment(массив $command, ListenerOptions $options)
Добавить параметр среды к данной команде.
protected массив createCommand(строка $connection, строка $queue, ListenerOptions $options)
Создать команду с параметрами слушателя.
void runProcess(Process $process, целое число $memory)
Запустить данный процесс.
protected void handleWorkerOutput(целое число $type, строка $line)
Обработать вывод от процесса рабочего процесса.
логический тип memoryExceeded(целое число $memoryLimit)
Определить, превышен ли лимит памяти.
void stop()
Остановить прослушивание и прервать выполнение скрипта.
void setOutputHandler(Closure $outputHandler)
Установить обратный вызов обработчика вывода.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/5.8/Illuminate/Queue/Listener.html
