BeanstalkdQueue
class BeanstalkdQueue extends Очередь implements Очередь (Просмотреть исходный код)
Свойства
| protected Контейнер | $container | Экземпляр контейнера IoC. | из Очередь |
| protected Pheanstalk | $pheanstalk | Экземпляр Pheanstalk. | |
| protected string | $default | Название очереди по умолчанию. | |
| protected int | $timeToRun | Время выполнения для всех поставленных задач. |
Методы
| mixed | pushOn(string $queue, string $job, mixed $data = '') Поместить новую задачу в очередь. | из Очередь |
| mixed | laterOn(string $queue, DateTime|int $delay, string $job, mixed $data = '') Поместить новую задачу в очередь с задержкой. | из Очередь |
| marshal() устарел Обработать запрос на добавление в очередь и выполнить задачу. | из Очередь | |
| mixed | bulk(array $jobs, mixed $data = '', string $queue = null) Поместить массив задач в очередь. | из Очередь |
| string | createPayload(string $job, mixed $data = '', string $queue = null) Создать строку полезной нагрузки из заданной задачи и данных. | из Очередь |
| array | createPlainPayload(string $job, mixed $data) Создать типичную, "простую" массив полезной нагрузки очереди. | из Очередь |
| mixed | prepareQueueableEntities(mixed $data) Подготовить любые сущности, подлежащие очереди, для хранения в очереди. | из Очередь |
| mixed | prepareQueueableEntity(mixed $value) Подготовить одну сущность, подлежащую очереди, для хранения в очереди. | из Очередь |
| string | createClosurePayload(Closure $job, mixed $data) Создать строку полезной нагрузки для заданной задачи Closure. | из Очередь |
| string | setMeta(string $payload, string $key, string $value) Установить дополнительные метаданные в строке полезной нагрузки. | из Очередь |
| int | getSeconds(DateTime|int $delay) Вычислить количество секунд с заданной задержкой. | из Очередь |
| int | getTime() Получить текущую метку времени Unix. | из Очередь |
| void | setContainer(Контейнер $container) Установить экземпляр контейнера IoC. | из Очередь |
| void | setEncrypter(Encrypter $crypt) Установить экземпляр шифратора. | из Очередь |
| void | __construct(Pheanstalk $pheanstalk, string $default, int $timeToRun) Создать новый экземпляр очереди Beanstalkd. | |
| 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) Поместить новую задачу в очередь с задержкой. | |
| Задача|null | pop(string $queue = null) Извлечь следующую задачу из очереди. | |
| void | deleteMessage(string $queue, string $id) Удалить сообщение из очереди Beanstalk. | |
| string | getQueue(string|null $queue) Получить очередь или вернуть очередь по умолчанию. | |
| Pheanstalk | getPheanstalk() Получить базовый экземпляр Pheanstalk. |
Подробности
mixed pushOn(string $queue, string $job, mixed $data = '')
Поместить новую задачу в очередь.
mixed laterOn(string $queue, DateTime|int $delay, string $job, mixed $data = '')
Поместить новую задачу в очередь с задержкой.
marshal() устарел
устарел
Обработать запрос на добавление в очередь и выполнить задачу.
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(Pheanstalk $pheanstalk, string $default, int $timeToRun)
Создать новый экземпляр очереди Beanstalkd.
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)
Извлечь следующее задание из очереди.
void deleteMessage(string $queue, string $id)
Удалить сообщение из очереди Beanstalk.
string getQueue(string|null $queue)
Получить очередь или вернуть значение по умолчанию.
Pheanstalk getPheanstalk()
Получить базовый экземпляр Pheanstalk.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/5.1/Illuminate/Queue/BeanstalkdQueue.html
