AMQPQueue::get
(PECL amqp >= Unknown)
AMQPQueue::get — Retrieve the next message from the queue.
Description
Retrieve the next available message from the queue. If no messages are present in the queue, this function will return FALSE immediately. This is a non blocking alternative to the AMQPQueue::consume() method.
Currently, the only supported flag for the flags parameter is AMQP_AUTOACK. If this flag is passed in, then the message returned will automatically be marked as acknowledged by the broker as soon as the frames are sent to the client.
Parameters
-
flags -
A bitmask of supported flags for the method call. Currently, the only the supported flag is
AMQP_AUTOACK. If this value is not provided, it will use the value of amqp.auto_ack.
Return Values
An instance of AMQPEnvelope representing the message pulled from the queue, or FALSE.
Examples
Example #1 AMQPQueue::get() example
<?php
/* Create a connection using all default credentials: */
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
/* create a queue object */
$queue = new AMQPQueue($channel);
//declare the queue
$queue->declare('myqueue');
//get the messages
$messages = $queue->get(AMQP_AUTOACK);
echo $message->getBody();
?>
0044 203 3971 555 (UK)