SqsQueue::laterOn()

mixed laterOn(string $queue, DateTime|int $delay, string $job, mixed $data = '') Push a new job onto the queue after a delay. Parameters string $queue DateTime|int $delay string $job mixed $data Return Value mixed

SqsQueue::later()

mixed later(DateTime|int $delay, string $job, mixed $data = '', string $queue = null) Push a new job onto the queue after a delay. Parameters DateTime|int $delay string $job mixed $data string $queue Return Value mixed

SqsQueue::getSqs()

SqsClient getSqs() Get the underlying SQS instance. Return Value SqsClient

SqsQueue::getQueue()

string getQueue(string|null $queue) Get the queue or return the default. Parameters string|null $queue Return Value string

SqsQueue::bulk()

mixed bulk(array $jobs, mixed $data = '', string $queue = null) Push an array of jobs onto the queue. Parameters array $jobs mixed $data string $queue Return Value mixed

SqsQueue

SqsQueue class SqsQueue extends Queue implements Queue (View source) Methods mixed pushOn(string $queue, string $job, mixed $data = '') Push a new job onto the queue. from Queue mixed laterOn(string $queue, DateTime|int $delay, string $job, mixed $data = '') Push a new job onto the queue after a delay. from Queue mixed bulk(array $jobs, mixed $data = '', string $queue = null) Push an array of jobs onto the queue. from Queue void setContainer(Container $container) Set the IoC c

SqsJob::__construct()

void __construct(Container $container, SqsClient $sqs, string $queue, array $job) Create a new job instance. Parameters Container $container SqsClient $sqs string $queue array $job Return Value void

SqsJob::resolveName()

string resolveName() Get the resolved name of the queued job class. Return Value string

SqsJob::release()

void release(int $delay) Release the job back into the queue. Parameters int $delay Return Value void

SqsJob::payload()

array payload() Get the decoded body of the job. Return Value array