AMQPQueue::get

(PECL amqp >= Unknown)

AMQPQueue::get — Récupère le prochain message depuis la file d'attente

Description

public mixed AMQPQueue::get ([ int $flags ] )

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();

?>