gianarb/lean-queue

LeanQueue

Master: Develop: , _(*1)

, _(*2)

lean queue system, receive and send messages for different queue adapters., _(*3)

For now supports ArrayAdapter and AwsSqs, _(*4)

Send messages in queue

<?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'}");

Receive and Delete messages

<?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);

Install

php composer.phar require "gianarb\lean-queue"

Contribute

Try it and open issues or pull requests! ;), _(*5)

vendor/bin/phpspec run