Слушатель
класс Слушатель (Просмотреть исходный код)
Свойства
| защищённая строка | $commandPath | Путь к исполняемой команде. | |
| защищённая строка | $environment | Окружение, в котором должны выполняться рабочие процессы. | |
| защищённое целое число | $sleep | Количество секунд ожидания перед опросом очереди. | |
| защищённое целое число | $maxTries | Количество попыток выполнения задания перед записью о его неудаче в журнал. | |
| защищённая обратная функция|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)
Обработать вывод от процесса рабочего процесса. | |
| bool | memoryExceeded(целое число $memoryLimit)
Определить, превышен ли предел памяти. | |
| никогда | stop()
Остановить прослушивание и выйти из скрипта. | |
| void | setOutputHandler(обратная функция $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)
Обработать вывод от процесса рабочего процесса.
bool memoryExceeded(целое число $memoryLimit)
Определить, превышен ли предел памяти.
никогда stop()
Остановить прослушивание и выйти из скрипта.
void setOutputHandler(обратная функция $outputHandler)
Установить обратную функцию обработчика вывода.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/10.x/Illuminate/Queue/Listener.html
