AMQPQueue::consume

(PECL amqp >= Unknown)

AMQPQueue::consume — Использовать цель

Описание

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

Это блокирующая функция, которая не будет возвращать ответа пока минимальное количество сообщений, указанное в min, не будет прочитано из очереди. Для использования неблокирующей функции смотри AMQPQueue::get().

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

options

options - массив используемых опций. Ключи, используемые в массиве options: min, max, и ack. Все другие ключи будут проигнорированы.

Для каждой недостающей опции расширение будет проверять ini-настройки или использовать значение по умолчанию.

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

Массив, содержащий использованные сообщения. Число возвращенных сообщений будет, по крайней мере, числом заданным min в массиве options. Но не больше, чем число заданное параметром max.

Примеры

Пример #1 Пример использования AMQPQueue::consume()


<?php

/* создание соединения, используя все учетные данные по умолчанию: */
$connection = new AMQPConnection();
$connection->connect();

/* создание очереди */
$queue = new AMQPQueue($connection);

//объявление очереди
$queue->declare('myqueue');

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

//получение сообщений
$messages = $queue->consume($options);

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

?>