AMQPQueue::get

(PECL amqp >= Unknown)

AMQPQueue::get — Retrieve the next message from the queue.

Descrizione

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

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

   ?>