AMQPQueue::get
(PECL amqp >= Unknown)
AMQPQueue::get — Récupère le prochain message depuis la file d'attente
Description
Récupère le prochain message disponible depuis la file d'attente.
Si aucun message n'est présent dans la file d'attente,
cette fonction retournera FALSE immédiatement.
C'est une alternative non bloquante à la méthode
AMQPQueue::consume().
Actuellement, le seul drapeau supporté pour le paramètre
flags est AMQP_AUTOACK.
Si ce drapeau est passé, alors le message retourné sera automatiquement
marqué comme connus du broker aussitôt que les frames
sont envoyées au client.
Liste de paramètres
-
flags -
Un masque de drapeaux supportés par l'appel de la méthode. Actuellement, le seul drapeau supporté est
AMQP_AUTOACK. Si la valeur n'est pas fournie, il utilisera la valeur de l'option de configuration amqp.auto_ack.
Valeurs de retour
Une instance de la classe AMQPEnvelope
représentant le message récupéré depuis la file d'attente,
ou FALSE.
Exemples
Exemple #1 AMQPQueue::get() example
<?php
/* Crée une connexion en utilisant les identifiants de connexion par défaut : */
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
/* Création d'un nouvel objet de file d'attente */
$queue = new AMQPQueue($channel);
// déclaration de la file d'attente
$queue->declare('myqueue');
// récupère le message suivant
$message = $queue->get(AMQP_AUTOACK);
echo $message->getBody();
?>