Home

A simple adaptable queue manager

$queue = new Corley\Queue\Queue(YOUR_QUEUE_NAME, $adapter);

Getting started

// send messages
$queue->send("message");

// receive messages
list($receipt, $message) = $queue->receive();

// remove a message
$queue->delete($receipt);

Create a new adapter

Just implements three methods from Corley\Queue\QueueInterface

public function send($queueName, $message, array $options);
public function receive($queueName, array $options);
public function delete($queueName, $receipt, array $options);

Available Adapters

• AWS SQS (Simple Queue Service) - https://github.com/wdalmut/queue-sqs
• RabbitMQ - https://github.com/wdalmut/queue-rabbitmq
• MySQL - https://github.com/wdalmut/queue-mysql
• Array (development/testing) - https://github.com/wdalmut/queue-array