AMQPQueue::get

(PECL amqp >= Unknown)

AMQPQueue::get — Получить следующее сообщение из очереди

Описание

public array AMQPQueue::get ([ int $flags = AMQP_NOACK ] )

Получает следующее сообщение из очереди. Это неблокирующая операция. Это означает, что если нет сообщений в очереди, то функция немедленно возвращает результат без каких-либо сообщений.

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

flags: Битовая маска флагов: AMQP_NOACK.

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

Возвращает массив, содержащий возможные ключи routing_key, exchange, delivery_tag, Content-type, Content-encoding, type, timestamp, priority, expiration, user_id, app_id, message_id, Reply-to, count, msg.

Примеры

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


<?php

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

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

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

//получение следующего сообщения
$message = $queue->get();

echo $message['msg'];

?>