Symbiote\SqsJobQueue\Service\SqsService
- Author: marcus
Synopsis
class SqsService
{
- // constants
- const MAX_DEPTH = 10;
- // members
- public SqsClient $client;
- public string $queueName = 'jobqueue';
- public $queueUrl;
- public array $handlers = ;
- public array $defaultTasks = ;
- // methods
- public void __call()
- public void sendSqsMessage()
- protected void getQueueUrl()
- public void readQueue()
- protected void updateTaskState()
- protected boolean canRestartTask()
- public void checkScheduledTasks()
- public void handleCall()
Constants
Name | Value |
---|---|
MAX_DEPTH | 10 |
Members
public
- $client — Symbiote\SqsJobQueue\Service\Aws\Sqs\SqsClient
- $defaultTasks
—
array
The list of tasks that the system will track as being regularly self triggered - $handlers
—
array
A map of handlers for messages that get sent. maps the message name to the object that handles that message (as a method) - $queueName
- $queueUrl
Methods
protected
- canRestartTask() — Check a task to see if it should be re-added to the execution queue
- getQueueUrl()
- updateTaskState() — Update the run-record state of a given task, if it tracks running time
public
- __call()
- checkScheduledTasks() — Checks through all the scheduled tasks that are expected to exist
- handleCall()
- readQueue()
- sendSqsMessage()