lean queue system, receive and send messages for different queue adapters.
For now supports ArrayAdapter
and AwsSqs
<?php
$client = \Aws\Sqs\SqsClient::factory();
$queue = new \GianArb\LeanQueue\Queue("https://sqs.eu-west-1.amazonaws.com/xxxxxx/test-php");
$queue->setAdapter(new \GianArb\LeanQueue\Adapter\AwsAdapter($client));
$queue->send("{'example': '2121'}");
<?php
$queue = new \GianArb\LeanQueue\Queue("https://sqs.eu-west-1.amazonaws.com/xxxxx/test-php");
$queue->setAdapter(new \GianArb\LeanQueue\Adapter\AwsAdapter($client));
list($receipt, $message) = $queue->receive();
$queue->delete($receipt);
php composer.phar require "gianarb\lean-queue"
Try it and open issues or pull requests! ;)
vendor/bin/phpspec run