AMQPQueue::consume

(PECL amqp >= Unknown)

AMQPQueue::consume — The consume purpose

Описание

public array AMQPQueue::consume ([ array $options = array() ] )

Внимание

К настоящему времени эта функция еще не была документирована; для ознакомления доступен только список аргументов.

Список параметров

options

options is a an array of consume options. The keys used in the options array are: min, max, and ack. All other keys will be ignored.

For each missing option, the extension will check the ini settings or use the default value.

Возвращаемые значения

An array containing the messages consumed. The number of returned messages will be at least the number given by min in the options array. But not more than the number given by max.

Примеры

Пример #1 AMQPQueue::consume() example


<?php

/* Create a connection using all default credentials: */
$connection = new AMQPConnection();
$connection->connect();

/* create a queue object */
$queue = new AMQPQueue($connection);

//declare the queue
$queue->declare('myqueue');

$options = array(
 'min' => 1,
 'max' => 10,
 'ack' => true
);

//get the messages
$messages = $queue->consume($options);

foreach ($messages as $message) {
 echo $message['message_body'];
}

?>