SyncQueue
class SyncQueue extends Очередь implements Очередь (Просмотреть исходный код)
Свойства
| protected Контейнер | $container | Экземпляр контейнера IoC. | из Очередь |
Методы
| смешанный | pushOn(строка $queue, строка $job, смешанный $data = '') Добавить новую задачу в очередь. | из Очередь |
| смешанный | laterOn(строка $queue, DateTime|целое $delay, строка $job, смешанный $data = '') Добавить новую задачу в очередь с задержкой. | из Очередь |
| marshal() устаревший Обработать запрос для добавления в очередь и выполнить задачу. | из Очередь | |
| смешанный | bulk(массив $jobs, смешанный $data = '', строка $queue = null) Добавить массив задач в очередь. | из Очередь |
| строка | createPayload(строка $job, смешанный $data = '', строка $queue = null) Создать строку полезной нагрузки из заданной задачи и данных. | из Очередь |
| массив | createPlainPayload(строка $job, смешанный $data) Создать обычный массив полезной нагрузки очереди. | из Очередь |
| смешанный | prepareQueueableEntities(смешанный $data) Подготовить любые сущности, способные находиться в очереди, для хранения в очереди. | из Очередь |
| смешанный | prepareQueueableEntity(смешанный $value) Подготовить одну сущность, способную находиться в очереди, для хранения в очереди. | из Очередь |
| строка | createClosurePayload(Closure $job, смешанный $data) Создать строку полезной нагрузки для заданной задачи Closure. | из Очередь |
| строка | setMeta(строка $payload, строка $key, строка $value) Установить дополнительные метаданные в строке полезной нагрузки. | из Очередь |
| целое | getSeconds(DateTime|целое $delay) Вычислить количество секунд с заданной задержкой. | из Очередь |
| целое | getTime() Получить текущую метку времени UNIX. | из Очередь |
| void | setContainer(Контейнер $container) Установить экземпляр контейнера IoC. | из Очередь |
| void | setEncrypter(Encrypter $crypt) Установить экземпляр шифрования. | из Очередь |
| смешанный | push(строка $job, смешанный $data = '', строка $queue = null) Добавить новую задачу в очередь. | |
| смешанный | pushRaw(строка $payload, строка $queue = null, массив $options = []) Добавить сырую полезную нагрузку в очередь. | |
| смешанный | later(DateTime|целое $delay, строка $job, смешанный $data = '', строка $queue = null) Добавить новую задачу в очередь с задержкой. | |
| Задача|null | pop(строка $queue = null) Извлечь следующую задачу из очереди. | |
| SyncJob | resolveJob(строка $payload, строка $queue) Разрешить экземпляр задачи Sync. | |
| void | raiseAfterJobEvent(Задача $job) Вызвать событие после выполнения задачи. | |
| массив | handleFailedJob(Задача $job) Обработать ошибочную задачу. | |
| void | raiseFailedJobEvent(Задача $job) Вызвать событие ошибки выполнения задачи. |
Подробности
смешанный pushOn(строка $queue, строка $job, смешанный $data = '')
Добавить новую задачу в очередь.
смешанный laterOn(строка $queue, DateTime|целое $delay, строка $job, смешанный $data = '')
Добавить новую задачу в очередь с задержкой.
marshal() устаревший
устаревший
Обработать запрос для добавления в очередь и выполнить задачу.
смешанный bulk(массив $jobs, смешанный $data = '', строка $queue = null)
Добавить массив задач в очередь.
protected строка createPayload(строка $job, смешанный $data = '', строка $queue = null)
Создать строку полезной нагрузки из заданной задачи и данных.
protected array createPlainPayload(string $job, mixed $data)
Создать массив типичного "простого" полезного груза очереди.
protected mixed prepareQueueableEntities(mixed $data)
Подготовить любые сущности, пригодные для очереди, для хранения в очереди.
protected mixed prepareQueueableEntity(mixed $value)
Подготовить одну сущность, пригодную для очереди, для хранения в очереди.
protected string createClosurePayload(Closure $job, mixed $data)
Создать строку полезного груза для заданной задачи Closure.
protected string setMeta(string $payload, string $key, string $value)
Установить дополнительную метаинформацию в строке полезного груза.
protected int getSeconds(DateTime|int $delay)
Вычислить количество секунд с заданным отсрочкой.
protected int getTime()
Получить текущую метку времени UNIX.
void setContainer(Container $container)
Установить экземпляр контейнера IoC.
void setEncrypter(Encrypter $crypt)
Установить экземпляр шифратора.
mixed push(string $job, mixed $data = '', string $queue = null)
Добавить новую задачу в очередь.
mixed pushRaw(string $payload, string $queue = null, array $options = [])
Добавить сырой полезный груз в очередь.
mixed later(DateTime|int $delay, string $job, mixed $data = '', string $queue = null)
Добавить новую задачу в очередь с отсрочкой.
Job|null pop(string $queue = null)
Извлечь следующую задачу из очереди.
protected SyncJob resolveJob(string $payload, string $queue)
Разрешить экземпляр задачи Sync.
protected void raiseAfterJobEvent(Job $job)
Вызвать событие после работы с задачей очереди.
protected array handleFailedJob(Job $job)
Обработать неудачную задачу.
protected void raiseFailedJobEvent(Job $job)
Вызвать событие неудачи задачи очереди.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/5.1/Illuminate/Queue/SyncQueue.html
