AMQPQueue::get

(PECL amqp >= Unknown)

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

说明

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.

参数

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.

返回值

An instance of AMQPEnvelope representing the message pulled from the queue, or FALSE.

范例

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

   ?>