IronQueue
class IronQueue extends Queue implements Queue (View source)
Свойства
| protected Container | $container | Экземпляр контейнера IoC. | из Queue |
| protected IronMQ | $iron | Экземпляр IronMQ. | |
| protected Request | $request | Текущий экземпляр запроса. | |
| protected string | $default | Имя по умолчанию очереди. | |
| protected bool | $shouldEncrypt | Указывает, должны ли сообщения быть зашифрованы. |
Методы
| mixed | pushOn(string $queue, string $job, mixed $data = '') Отправить новую задачу в очередь. | from Queue |
| mixed | laterOn(string $queue, DateTime|int $delay, string $job, mixed $data = '') Отправить новую задачу в очередь с задержкой. | from Queue |
| marshal() deprecated Обработать запрос очереди отправки и запустить задачу. | ||
| mixed | bulk(array $jobs, mixed $data = '', string $queue = null) Отправить массив задач в очередь. | from Queue |
| string | createPayload(string $job, mixed $data = '', string $queue = null) Создать строку полезной нагрузки из заданной задачи и данных. | |
| array | createPlainPayload(string $job, mixed $data) Создать типичный массив полезной нагрузки очереди. | from Queue |
| mixed | prepareQueueableEntities(mixed $data) Подготовить все сущности, которые можно поместить в очередь, для хранения в очереди. | from Queue |
| mixed | prepareQueueableEntity(mixed $value) Подготовить одну сущность, которую можно поместить в очередь, для хранения в очереди. | from Queue |
| string | createClosurePayload(Closure $job, mixed $data) Создать строку полезной нагрузки для заданной задачи Closure. | from Queue |
| string | setMeta(string $payload, string $key, string $value) Установить дополнительные метаданные в строке полезной нагрузки. | from Queue |
| int | getSeconds(DateTime|int $delay) Вычислить количество секунд с заданной задержкой. | from Queue |
| int | getTime() Получить текущую метку времени UNIX. | from Queue |
| void | setContainer(Container $container) Установить экземпляр контейнера IoC. | from Queue |
| void | setEncrypter(Encrypter $crypt) Установить экземпляр шифрования. | from Queue |
| void | __construct(IronMQ $iron, Request $request, string $default, bool $shouldEncrypt = false) Создать новый экземпляр очереди IronMQ. | |
| mixed | push(string $job, mixed $data = '', string $queue = null) Отправить новую задачу в очередь. | |
Details
mixed pushOn(string $queue, string $job, mixed $data = '')
Отправить новую задачу в очередь.
mixed laterOn(string $queue, DateTime|int $delay, string $job, mixed $data = '')
Отправить новую задачу в очередь с задержкой.
marshal() deprecated
deprecated
Отправить запрос очереди обработки и запустить задачу.
mixed bulk(array $jobs, mixed $data = '', string $queue = null)
Добавить массив задач в очередь.
protected string createPayload(string $job, mixed $data = '', string $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)
Установить экземпляр шифрования.
void __construct(IronMQ $iron, Request $request, string $default, bool $shouldEncrypt = false)
Создать новый экземпляр очереди IronMQ.
mixed push(string $job, mixed $data = '', string $queue = null)
Добавить новую задачу в очередь.
mixed pushRaw(string $payload, string $queue = null, array $options = [])
Добавить сырой фрагмент данных в очередь.
mixed recreate(string $payload, string $queue, int $delay)
Добавить сырой фрагмент данных в очередь после шифрования.
mixed later(DateTime|int $delay, string $job, mixed $data = '', string $queue = null)
Добавить новую задачу в очередь с задержкой.
Задача|null pop(string $queue = null)
Извлечь следующую задачу из очереди.
void deleteMessage(string $queue, string $id)
Удалить сообщение из очереди Iron.
protected object marshalPushedJob()
Отправляет на обработку поставленное задание и полезную нагрузку.
protected IronJob createPushedIronJob(object $job)
Создаёт новое задание IronJob для поставленного задания.
protected string parseJobBody(string $body)
Парсит тело задания для запуска.
string getQueue(string|null $queue)
Возвращает очередь или по умолчанию.
IronMQ getIron()
Возвращает базовый экземпляр IronMQ.
Request getRequest()
Получить экземпляр запроса.
void setRequest(Request $request)
Установить экземпляр запроса.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/5.3/Illuminate/Queue/IronQueue.html
