mehr-it / lara-sqs-plain
Receive custom/plain SQS messages in Laravel
Requires
- php: >=7.0.0
- ext-json: *
- aws/aws-sdk-php: ~3.0
- laravel/framework: ^5.7.7|^6.0|^7.0|^8.0
- mehr-it/lara-sqs-ext: ^2.8.1|^3.0
Requires (Dev)
- orchestra/testbench: ^3.8|^4.0|^5.0|^6.0
- phpunit/phpunit: ^7.4|^8.5
This package is auto-updated.
Last update: 2024-10-20 21:33:28 UTC
README
Allows to receive custom/plain SQS messages in Laravel. This is very useful if you have to work with third party messages not dispatched from Laravel.
You receive the plain message content in the constructor of your handler classes. You may specify your own handler class for each queue.
This package is based on the mehr-it/lara-sqs-ext package and implements most of it's features.
Installation
composer require mehr-it/lara-sqs-plain
This package uses Laravel's package auto-discovery, so the service provider will be loaded automatically.
Queue configuration
Just configure a queue connection as you would configure any other SQS queue in Laravel.
The only difference is the message_handler
option, which must be the name of the class which should
handle the messages:
'sqs-plain-conn' => [
'driver' => 'sqs-plain',
'key' => '112233445566778899',
'secret' => 'xxxxxxxxxxxxxxxxxxxxxxxxxx',
'prefix' => 'https://sqs.eu-central-1.amazonaws.com/11223344556677',
'queue' => 'msgs',
'region' => 'eu-central-1',
'message_handler' => 'App\\Job\\MyPlainHandler',
],
Long polling
To enable long polling, you may add the option message_wait_timeout
to the queue
configuration. This sets the WaitTimeSeconds
parameter to the configured amount of time.
'message_wait_timeout' => 20,
Message handlers
To create a handler for SQS messages, simply extend the SqsPlainMessageHandler
class.
The handle
function will be invoked for each message and the raw message body will
be available in the message
attribute:
class MyPlainHandler extends SqsPlainMessageHandler {
public function handle() {
$rawMessage = $this->message;
}
}
The InteractsWithQueue
and InteractsWithSqsQueue
trait is already implemented in the base class, so you can interact
with the queue.
Message handlers my define the same properties as common jobs, to control the job
workers. This includes tries
, timeout
, timeoutAt
, automaticQueueVisibility
,
automaticQueueVisibilityExtra
or the retryUntil
method.
Thanks
Thanks to Jussi Hamalainen who wrote the jusahah/laravel-sqs-jobless
package which served
as guideline for this package.