Выполняет операцию чтения следующего фрейма


stomp_read_frame

(PECL stomp >= 0.1.0)

Stomp::readFrame -- stomp_read_frameВыполняет операцию чтения следующего фрейма

Описание

Объектно-ориентированный стиль (метод):

public stompframe Stomp::readFrame ([ string $class_name = "stompFrame" ] )

Процедурный стиль:

array stomp_read_frame ( resource $link )

Выполняет операцию чтения следующего фрейма. Если возможно, то создаёт экземпляр указанного класса и передаёт параметры конструктору этого класса.

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

link

Только для процедурного стиля: Идентификатор соединения stomp, полученный из stomp_connect().

class_name

Имя класса для создания экземпляра. Если не указан, возвращается объект stompFrame.

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

Замечание:

Также может быть указан заголовок транзакции, означающий что прием сообщения должен являться частью именованной транзакции.

Список изменений

Версия Описание
Stomp 0.4.0 Добавлен параметр class_name.

Примеры

Пример #1 Объектно-ориентированный стиль

<?php

/* подключение */
try {
    
$stomp = new Stomp('tcp://localhost:61613');
} catch(
StompException $e) {
    die(
'Ошибка соединения: ' $e->getMessage());
}

/* подписка на сообщения из очереди 'foo' */
$stomp->subscribe('/queue/foo');

/* чтение фрейма */
var_dump($stomp->readFrame());

/* закрытие подключения */
unset($stomp);

?>

Результатом выполнения данного примера будет что-то подобное:

 object(StompFrame)#2 (3) {   ["command"]=>   string(7) "MESSAGE"   ["headers"]=>   array(5) {     ["message-id"]=>     string(41) "ID:php.net-55293-1257226743606-4:2:-1:1:1"     ["destination"]=>     string(10) "/queue/foo"     ["timestamp"]=>     string(13) "1257226805828"     ["expires"]=>     string(1) "0"     ["priority"]=>     string(1) "0"   }   ["body"]=>   string(3) "bar" } 

Пример #2 Процедурный стиль

<?php

/* подключение */
$link stomp_connect('ssl://localhost:61612');

/* проверка соединения */
if (!$link) {
    die(
'Ошибка соединения: ' stomp_connect_error());
}

/* подписка на сообщения из очереди 'foo' */
stomp_subscribe($link'/queue/foo');

/* чтение фрейма */
$frame stomp_read_frame($link);

/* закрытие подключения */
stomp_close($link);

?>

Результатом выполнения данного примера будет что-то подобное:

 array(3) {   ["command"]=>   string(7) "MESSAGE"   ["body"]=>   string(3) "bar"   ["headers"]=>   array(6) {     ["transaction"]=>     string(2) "t1"     ["message-id"]=>     string(41) "ID:php.net-55293-1257226743606-4:3:-1:1:1"     ["destination"]=>     string(10) "/queue/foo"     ["timestamp"]=>     string(13) "1257227037059"     ["expires"]=>     string(1) "0"     ["priority"]=>     string(1) "0"   } }