AMQPQueue::get
(PECL amqp >= Unknown)
AMQPQueue::get — Retrieve the next message from the queue.
Description
public array AMQPQueue::get
([ int $flags = AMQP_NOACK
] )
Retrieve the next message from the queue. This is a non-blocking operation, which means that if there is no message on the queue, the function will return immediately with no message.
Parameters
- flags
-
A bitmask of any of the flags: AMQP_NOACK.
Return Values
Returns array possibly containing keys routing_key, exchange, delivery_tag, Content-type, Content-encoding, type, timestamp, priority, expiration, user_id, app_id, message_id, Reply-to, count, msg.
Examples
Example #1 AMQPQueue::get example
<?php
/* Create a connection using all default credentials: */
$connection = new AMQPConnection();
$connection->connect();
/* create a queue object */
$queue = new AMQPQueue($connection);
//declare the queue
$queue->declare('myqueue');
//get the next message
$message = $queue->get();
echo $message['msg'];
?>