Create

$queue =newQueue("queue name",$queueAdapter);

Available Adapters

Receive from queue

list($receipt,$message) =$queue->receive();// receive with optionslist($receipt,$message) =$queue->receive(["timeout" =>15*60]);

Send in queue

$queue->send("my message");// send with options$queue->send("my message", ["delay" =>20]);

Delete from queue

$queue->delete($receipt);// delete with options$queue->delete($receipt, ["delay" =>20]);

Manage different adapters options

$queue =newQueue("https://sqs.amazon.com/39857/urs",$sqsAdapter);$queue->send("message",toSQS(["delay" =>20]));functiontoSQS(array options = []) {$opts = [];if (array_key_exists("delay",$options)) {$opts["DelaySeconds"] =$options["delay"];    }return$opts;}

Queue Interface (for adapters)

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

Tips on return values (receive message)