To use this package you need Corley\Queue\Queue
composer require corley/queue:~1
use Corley\Queue\Queue;
use Corley\Queue\ArrayAdapter\ArrayAdapter;
$adapter = new ArrayAdapter();
$queue = new Queue("example", $adapter);
$queue->send(json_encode(["test" => "ok"]));
list($receipt, $message) = $queue->receive();
$message = json_decode($message, true);
$queue->delete($receipt);