Работник очереди
класс Работник очереди (Просмотреть исходный код)
Свойства
| protected Менеджер очереди | $manager | Экземпляр менеджера очереди. | |
| protected Интерфейс поставщика завершившихся заданий | $failer | Реализация поставщика завершившихся заданий. | |
| protected Диспечер событий | $events | Экземпляр диспечера событий. | |
| protected Репозиторий кэша | $cache | Реализация репозитория кэша. | |
| protected Обработчик исключений | $exceptions | Экземпляр обработчика исключений. |
Методы
| void | __construct(Менеджер очереди $manager, Интерфейс поставщика завершившихся заданий $failer = null, Диспечер событий $events = null) Создать нового работника очереди. | |
| массив | daemon(строка $connectionName, строка $queue = null, целое $delay, целое $memory = 128, целое $sleep = 3, целое $maxTries) Прослушивать заданную очередь в цикле. | |
| void | runNextJobForDaemon(строка $connectionName, строка $queue, целое $delay, целое $sleep, целое $maxTries) Выполнить следующую задачу для работника демона. | |
| булево | daemonShouldRun() Определить, должен ли демон обрабатывать на этой итерации. | |
| массив | pop(строка $connectionName, строка $queue = null, целое $delay, целое $sleep = 3, целое $maxTries) Прослушивать заданную очередь. | |
| Задание|null | getNextJob(Очередь $connection, строка $queue) Получить следующую задачу из подключения к очереди. | |
| void | process(строка $connection, Задание $job, целое $maxTries, целое $delay) Обработать заданную задачу из очереди. | |
| массив | logFailedJob(строка $connection, Задание $job) Залогировать завершившуюся задачу в хранилище. | |
| void | raiseFailedJobEvent(строка $connection, Задание $job) Вызвать событие завершившейся задачи очереди. | |
| булево | memoryExceeded(целое $memoryLimit) Определить, превышен ли лимит памяти. | |
| void | stop() Остановить прослушивание и прервать выполнение скрипта. | |
| void | sleep(целое $seconds) Заставить скрипт уснуть на заданное количество секунд. | |
| целое|null | getTimestampOfLastQueueRestart() Получить отметку времени последней перезагрузки очереди или null. | |
| булево | queueShouldRestart(целое|null $lastRestart) Определить, должен ли работник очереди перезапуститься. | |
| void | setDaemonExceptionHandler(Обработчик исключений $handler) Установить обработчик исключений для использования в режиме демона. | |
| void | setCache(Репозиторий кэша $cache) Установить реализацию репозитория кэша. | |
| Менеджер очереди | getManager() Получить экземпляр менеджера очереди. | |
| void | setManager(Менеджер очереди $manager) Установить экземпляр менеджера очереди. |
Подробности
void __construct(Менеджер очереди $manager, Интерфейс поставщика завершившихся заданий $failer = null, Диспечер событий $events = null)
Создать нового работника очереди.
массив daemon(строка $connectionName, строка $queue = null, целое $delay, целое $memory = 128, целое $sleep = 3, целое $maxTries)
Прослушивать заданную очередь в цикле.
protected void runNextJobForDaemon(строка $connectionName, строка $queue, целое $delay, целое $sleep, целое $maxTries)
Выполнить следующую задачу для работника демона.
protected bool daemonShouldRun()
Определить, должен ли демон обрабатывать на этой итерации.
массив pop(строка $connectionName, строка $queue = null, целое $delay, целое $sleep = 3, целое $maxTries)
Прослушивать заданную очередь.
protected Задание|null getNextJob(Очередь $connection, строка $queue)
Получить следующую задачу из подключения к очереди.
void process(string $connection, Job $job, int $maxTries, int $delay)
Обработать заданный job из очереди.
protected array logFailedJob(string $connection, Job $job)
Записать в хранилище информацию о сбое job.
protected void raiseFailedJobEvent(string $connection, Job $job)
Вызвать событие сбоя задания из очереди.
bool memoryExceeded(int $memoryLimit)
Определить, превышен ли лимит памяти.
void stop()
Остановить прослушивание и выйти из скрипта.
void sleep(int $seconds)
Засыпать скрипт на заданное количество секунд.
protected int|null getTimestampOfLastQueueRestart()
Получить метку времени последней перезагрузки очереди или null.
protected bool queueShouldRestart(int|null $lastRestart)
Определить, должен ли рабочий процесс очереди перезапуститься.
void setDaemonExceptionHandler(Handler $handler)
Установить обработчик исключений для использования в режиме Daemon.
void setCache(Repository $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/4.2/Illuminate/Queue/Worker.html
