Рабочий
класс Worker (View source)
Свойства
| protected QueueManager | $manager | Экземпляр менеджера очереди. | |
| protected FailedJobProviderInterface | $failer | Реализация поставщика невыполненных заданий. | |
| protected Dispatcher | $events | Экземпляр диспетчера событий. | |
| protected Repository | $cache | Реализация репозитория кэша. | |
| protected Handler | $exceptions | Экземпляр обработчика исключений. |
Методы
| void | __construct(QueueManager $manager, FailedJobProviderInterface $failer = null, Dispatcher $events = null) Создать новый рабочий поток очереди. | |
| array | daemon(string $connectionName, string $queue = null, int $delay, int $memory = 128, int $sleep = 3, int $maxTries) Прослушивать заданную очередь в цикле. | |
| void | runNextJobForDaemon(string $connectionName, string $queue, int $delay, int $sleep, int $maxTries) Выполнить следующее задание для фонового рабочего процесса. | |
| bool | daemonShouldRun() Определить, должен ли фоновый процесс обрабатывать на этой итерации. | |
| array | pop(string $connectionName, string $queue = null, int $delay, int $sleep = 3, int $maxTries) Прослушивать заданную очередь. | |
| Job|null | getNextJob(Queue $connection, string $queue) Получить следующее задание из соединения очереди. | |
| array|null | process(string $connection, Job $job, int $maxTries, int $delay) Обработать заданное задание из очереди. | |
| void | handleJobException(string $connection, Job $job, int $delay, Throwable $e) Обработать исключение, возникшее во время выполнения задания. | |
| void | raiseBeforeJobEvent(string $connection, Job $job) Вызвать событие перед выполнением задания очереди. | |
| void | raiseAfterJobEvent(string $connection, Job $job) Вызвать событие после выполнения задания очереди. | |
| void | raiseExceptionOccurredJobEvent(string $connection, Job $job, Throwable $exception) Вызвать событие о возникновении исключения в задании очереди. | |
| array | logFailedJob(string $connection, Job $job) Записать в журнал невыполненное задание в хранилище. | |
| void | raiseFailedJobEvent(string $connection, Job $job, int|null $failedId) Вызвать событие о невыполненном задании очереди. | |
| bool | memoryExceeded(int $memoryLimit) Определить, был ли превышен лимит памяти. | |
| void | stop() Остановить прослушивание и выйти из скрипта. | |
| void | sleep(int $seconds) Задержать выполнение скрипта на указанное количество секунд. | |
| int|null | getTimestampOfLastQueueRestart() Получить метку времени последнего перезапуска очереди или null. | |
| bool | queueShouldRestart(int|null $lastRestart) Определить, следует ли перезапускать обработчик очереди. | |
| void | setDaemonExceptionHandler(ExceptionHandler $handler) Установить обработчик исключений для использования в режиме Daemon. | |
| void | setCache(Repository $cache) Установить реализацию репозитория кэша. | |
| QueueManager | getManager() Получить экземпляр менеджера очереди. | |
| void | setManager(QueueManager $manager) Установить экземпляр менеджера очереди. |
Подробности
void __construct(QueueManager $manager, FailedJobProviderInterface $failer = null, Dispatcher $events = null)
Создать новый рабочий поток очереди.
array daemon(string $connectionName, string $queue = null, int $delay, int $memory = 128, int $sleep = 3, int $maxTries)
Прослушивать заданную очередь в цикле.
protected void runNextJobForDaemon(string $connectionName, string $queue, int $delay, int $sleep, int $maxTries)
Выполнить следующее задание для фонового рабочего процесса.
protected bool daemonShouldRun()
Определить, должен ли фоновый процесс обрабатывать на этой итерации.
массив pop(строка $connectionName, строка $queue = null, целое $delay, целое $sleep = 3, целое $maxTries)
Прослушивать указанную очередь.
защищенный Задача|null getNextJob(Очередь $connection, строка $queue)
Получить следующую задачу из соединения очереди.
массив|null process(строка $connection, Задача $job, целое $maxTries, целое $delay)
Обработать заданную задачу из очереди.
защищенный пустое handleJobException(строка $connection, Задача $job, целое $delay, Throwable $e)
Обработать исключение, возникшее во время выполнения задачи.
защищенный пустое raiseBeforeJobEvent(строка $connection, Задача $job)
Вызвать событие перед задачей очереди.
защищенный пустое raiseAfterJobEvent(строка $connection, Задача $job)
Вызвать событие после задачи очереди.
защищенный пустое raiseExceptionOccurredJobEvent(строка $connection, Задача $job, Throwable $exception)
Вызвать событие возникновения исключения в задаче очереди.
защищенный массив logFailedJob(строка $connection, Задача $job)
Залогировать проваленную задачу в хранилище.
защищенный пустое raiseFailedJobEvent(строка $connection, Задача $job, целое|null $failedId)
Вызвать событие проваленной задачи очереди.
логическое memoryExceeded(целое $memoryLimit)
Определить, превышен ли лимит памяти.
пустое stop()
Остановить прослушивание и выйти из скрипта.
пустое sleep(целое $seconds)
Засыпать скрипт на заданное количество секунд.
защищенный целое|null getTimestampOfLastQueueRestart()
Получить временную метку последнего перезапуска очереди, или null.
защищенный логическое queueShouldRestart(целое|null $lastRestart)
Определить, должен ли рабочий процесс очереди перезапуститься.
пустое setDaemonExceptionHandler(ОбработчикИсключений $handler)
Установить обработчик исключений для использования в режиме Daemon.
пустое setCache(Репозиторий $cache)
Установить реализацию репозитория кэша.
QueueManager getManager()
Получить экземпляр диспетчера очереди.
void setManager(QueueManager $manager)
Установить экземпляр диспетчера очереди.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/5.2/Illuminate/Queue/Worker.html
