AMQPQueue::deleteAMQPQueue::get
(PECL amqp >= Unknown)
AMQPQueue::get — Retrieve the next message from the queue.
Descrizione
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.
Elenco dei parametri
-
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.
Valori restituiti
An instance of AMQPEnvelope representing the message pulled from the queue, or FALSE.
Esempi
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();
?>
add a note
User Contributed Notes
AMQPQueue::get - [0 notes]