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