SqsQueue
class SqsQueue extends Queue implements QueueInterface (View source)
Properties
| protected Container | $container | The IoC container instance. |
from Queue |
| protected SqsClient | $sqs | The Amazon SQS instance. |
|
| protected string | $default | The name of the default tube. |
Methods
Push an array of jobs onto the queue.
Create a payload string from the given job and data.
Set additional meta on a payload string.
Create a new Amazon SQS queue instance.
Push a new job onto the queue.
Push a raw payload onto the queue.
Get the queue or return the default.
Get the underlying SQS instance.
Details
in
Queue at line 23
marshal()
Marshal a push queue request and fire the job.
in
Queue at line 36
mixed
bulk(array $jobs, mixed $data = '', string $queue = null)
Push an array of jobs onto the queue.
in
Queue at line 52
protected string
createPayload(string $job, mixed $data = '', string $queue = null)
Create a payload string from the given job and data.
in
Queue at line 69
protected string
createClosurePayload(Closure $job, mixed $data)
Create a payload string for the given Closure job.
in
Queue at line 84
protected string
setMeta(string $payload, string $key, string $value)
Set additional meta on a payload string.
in
Queue at line 97
protected int
getSeconds(DateTime|int $delay)
Calculate the number of seconds with the given delay.
in
Queue at line 112
int
getTime()
Get the current UNIX timestamp.
in
Queue at line 123
void
setContainer(Container $container)
Set the IoC container instance.
in
Queue at line 134
void
setEncrypter(Encrypter $crypt)
Set the encrypter instance.
void
__construct(SqsClient $sqs, string $default)
Create a new Amazon SQS queue instance.
mixed
push(string $job, mixed $data = '', string $queue = null)
Push a new job onto the queue.
mixed
pushRaw(string $payload, string $queue = null, array $options = array())
Push a raw payload onto the queue.
mixed
later(DateTime|int $delay, string $job, mixed $data = '', string $queue = null)
Push a new job onto the queue after a delay.
Job|null
pop(string $queue = null)
Pop the next job off of the queue.
string
getQueue(string|null $queue)
Get the queue or return the default.
SqsClient
getSqs()
Get the underlying SQS instance.