graze / queue
:postbox: Flexible abstraction for working with queues in PHP.
Installs: 44 176
Dependents: 0
Suggesters: 0
Security: 0
Stars: 49
Watchers: 26
Forks: 10
Open Issues: 6
Requires
- php: ^5.5|^7
- graze/data-structure: ^2
Requires (Dev)
- aws/aws-sdk-php: ^3
- graze/hamcrest-test-listener: ^2|^3
- graze/standards: ^2
- hamcrest/hamcrest-php: ^2
- mockery/mockery: ^1
- phpunit/phpunit: ^5.7.21|^6|^7
- squizlabs/php_codesniffer: ^3
Suggests
- aws/aws-sdk-php: Required when using the SQS Adapter
This package is auto-updated.
Last update: 2024-10-24 04:33:13 UTC
README
This library provides a flexible abstraction layer for working with queues.
It can be installed in whichever way you prefer, but we recommend Composer.
~$ composer require graze/queue
Documentation
Queue operations center around lists of Message objects. Whether you're sending one or multiple Messages, it's always an array. Workers work only on one Message object at a time, whether a list of one or multiple is received from the queue.
use Aws\Sqs\SqsClient; use Graze\Queue\Adapter\SqsAdapter; use Graze\Queue\Client; use Graze\Queue\Message\MessageInterface; $client = new Client(new SqsAdapter(new SqsClient([ 'region' => 'us-east-1', 'version' => '2012-11-05', 'credentials' => [ 'key' => 'ive_got_the_key', 'secret' => 'ive_got_the_secret' ], ]), 'queue_name')); // Producer $client->send([ $client->create('foo'), ]); // Consumer $client->receive(function (MessageInterface $msg) { var_dump($msg->getBody()); var_dump($msg->getMetadata()->getAll()); });
Adapters
The Adapter object is used to fulfill the low level requests to the queue provider.
Currently supported queue providers are:
Handlers
The Handler object is used to execute worker callables with a list of received messages and handle Acknowledgement.
The current handlers are:
- Batch Acknowledgement to acknowledge batches
- Eager Acknowledgement to acknowledge immediately after work
- Null Acknowledgement for development
use Graze\Queue\Client; use Graze\Queue\Adapter\ArrayAdapter; use Graze\Queue\Handler\BatchAcknowledgementHandler; use Graze\Queue\Message\MessageInterface; // Create client with the Batch Acknowledgement Handler. $client = new Client(new ArrayAdapter(), [ 'handler' => new BatchAcknowledgementHandler(), ]); // Receive a maximum of 10 messages. $client->receive(function (MessageInterface $message) { // Do some work. }, 10);
Polling
Polling a queue is supported by passing null
as the limit argument to the
receive
method. The second argument given to your worker is a Closure
you
should use to stop polling when you're finished working. Make sure you use a
handler that acknowledges work effectively too!
Note that the individual Adapter objects may decide to stop polling at any time. A likely scenario where it may stop would be if the queue is of finite length and all possible messages have been received.
use Graze\Queue\Client; use Graze\Queue\Adapter\ArrayAdapter; use Graze\Queue\Handler\BatchAcknowledgementHandler; use Graze\Queue\Message\MessageInterface; // Create client with the Batch Acknowledgement Handler. $client = new Client(new ArrayAdapter(), [ 'handler' => new BatchAcknowledgeHandler(100), // Acknowledge after 100 messages. ]); // Poll until `$done()` is called. $client->receive(function (MessageInterface $message, Closure $done) { // Do some work. // You should always define a break condition (i.e. timeout, expired session, etc). if ($breakCondition) $done(); }, null);
License
The content of this library is released under the MIT License by Nature Delivered Ltd.
You can find a copy of this license in LICENSE
or at http://opensource.org/licenses/mit.