SqsQueue

class SqsQueue extends Очередь implements Интерфейс очереди (Просмотреть исходный код)

Свойства

protected Контейнер	$container	Экземпляр контейнера IoC.	из Очередь
protected SqsClient	$sqs	Экземпляр Amazon SQS.
protected string	$default	Имя стандартной очереди.

Методы

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(SqsClient $sqs, string $default)

Создание нового экземпляра очереди Amazon SQS.

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)

Извлечение следующего задания из очереди.

string

getQueue(string|null $queue)

Получение очереди или возврат значения по умолчанию.

SqsClient

getSqs()

Получение базового экземпляра SQS.

Подробности

marshal()

Обработка запроса на добавление в очередь и запуск задания.

Исключения

RuntimeException

mixed bulk(array $jobs, mixed $data = '', string $queue = null)

Добавление массива заданий в очередь.

Параметры

array	$jobs
mixed	$data
string	$queue

Возвращаемое значение

mixed

protected string createPayload(string $job, mixed $data = '', string $queue = null)

Создание строки полезной нагрузки из заданного задания и данных.

Параметры

string	$job
mixed	$data
string	$queue

Возвращаемое значение

string

protected string createClosurePayload(Closure $job, mixed $data)

Создание строки полезной нагрузки для заданного задания Closure.

Параметры

Closure	$job
mixed	$data

Возвращаемое значение

string

protected string setMeta(string $payload, string $key, string $value)

Установка дополнительных метаданных в строке полезной нагрузки.

Параметры

string	$payload
string	$key
string	$value

Возвращаемое значение

string

protected int getSeconds(DateTime|int $delay)

Вычисление количества секунд с заданной задержкой.

Параметры

DateTime|int

$delay

Возвращаемое значение

int

int getTime()

Получение текущего UNIX-времени.

Возвращаемое значение

int

void setContainer(Контейнер $container)

Установка экземпляра контейнера IoC.

Параметры

Контейнер

$container

Возвращаемое значение

void

void setEncrypter(Encrypter $crypt)

Установка экземпляра шифрования.

Параметры

Encrypter

$crypt

Возвращаемое значение

void

END_OF_DOCUMENT_MARKER

void __construct(SqsClient $sqs, string $default)

Создать новую очередь Amazon SQS.

Параметры

SqsClient	$sqs
string	$default

Возвращаемое значение

void

mixed push(string $job, mixed $data = '', string $queue = null)

Добавить новую задачу в очередь.

Параметры

string	$job
mixed	$data
string	$queue

Возвращаемое значение

mixed

mixed pushRaw(string $payload, string $queue = null, array $options = array())

Добавить сырой фрагмент данных в очередь.

Параметры

string	$payload
string	$queue
array	$options

Возвращаемое значение

mixed

mixed later(DateTime|int $delay, string $job, mixed $data = '', string $queue = null)

Добавить новую задачу в очередь с задержкой.

Параметры

DateTime\|int	$delay
string	$job
mixed	$data
string	$queue

Возвращаемое значение

mixed

Задача|null pop(string $queue = null)

Извлечь следующую задачу из очереди.

Параметры

string

$queue

Возвращаемое значение

Задача|null

string getQueue(string|null $queue)

Получить очередь или вернуть значение по умолчанию.

Параметры

string|null

$queue

Возвращаемое значение

string

SqsClient getSqs()

Получить базовый экземпляр SQS.

Возвращаемое значение

SqsClient

© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/4.2/Illuminate/Queue/SqsQueue.html