Регистрация Войти
Войти через VK




Поиск по сайту



PHP Поиск



Для вас в нашей компании тумба под тв на заказ для всех желающих.

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()
/* создание соединения, используя все учетные данные по умолчанию: */
$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'];
}


Описание класса amqpqueue, примеры использования класса amqpqueue.



Смотрите также:
Описание на ru2.php.net
Описание на php.ru

.

Популярное:


Содержание:


Новое за неделю



Сейчас на сайте: 1239