Класс Stomp

(PECL stomp >= 0.1.0)

Введение

Представляет связь между PHP и Stomp совместимым брокером сообщений (Message Broker).

Обзор класса

class Stomp {

/* Методы */

public function __construct (
string $broker = ini_get("stomp.default_broker_uri"),
string $username = ?,
string $password = ?,
array $headers = ?
)

public function abort (string $transaction_id, array $headers = ?): bool

function stomp_abort(resource $link, string $transaction_id, array $headers = ?): bool

public function ack (mixed $msg, array $headers = ?): bool

function stomp_ack(resource $link, mixed $msg, array $headers = ?): bool

public function begin (string $transaction_id, array $headers = ?): bool

function stomp_begin(resource $link, string $transaction_id, array $headers = ?): bool

public function commit (string $transaction_id, array $headers = ?): bool

function stomp_commit(resource $link, string $transaction_id, array $headers = ?): bool

function stomp_connect(
string $broker = ini_get("stomp.default_broker_uri"),
string $username = ?,
string $password = ?,
array $headers = ?
): resource

function stomp_close(resource $link): bool

public function error (): string

function stomp_error(resource $link): string

public function getReadTimeout (): array

function stomp_get_read_timeout(resource $link): array

public function getSessionId (): string |false

function stomp_get_session_id(resource $link): string |false

public function hasFrame (): bool

function stomp_has_frame(resource $link): bool

public function readFrame (string $class_name = "stompFrame"): stompframe

function stomp_read_frame(resource $link): array

public function send (string $destination, mixed $msg, array $headers = ?): bool

function stomp_send(
resource $link,
string $destination,
mixed $msg,
array $headers = ?
): bool

public function setReadTimeout (int $seconds, int $microseconds = ?): void

function stomp_set_read_timeout(resource $link, int $seconds, int $microseconds = ?): void

public function subscribe (string $destination, array $headers = ?): bool

function stomp_subscribe(resource $link, string $destination, array $headers = ?): bool

public function unsubscribe (string $destination, array $headers = ?): bool

function stomp_unsubscribe(resource $link, string $destination, array $headers = ?): bool

public function __destruct ()

}

Содержание

Stomp::abort — Отменяет выполнение текущей транзакции
Stomp::ack — Подтверждает получение сообщения
Stomp::begin — Создаёт транзакцию
Stomp::commit — Выполняет текущую транзакцию
Stomp::__construct — Открывает соединение
Stomp::__destruct — Закрывает Stomp-соединение
Stomp::error — Возвращает последнюю ошибку Stomp
Stomp::getReadTimeout — Возвращает время максимального ожидания операции чтения
Stomp::getSessionId — Возвращает идентификатор текущей сессии Stomp
Stomp::hasFrame — Проверяет, возможно ли чтение фрейма
Stomp::readFrame — Считывает следующий кадр
Stomp::send — Отправляет сообщение
Stomp::setReadTimeout — Устанавливает предельное время ожидания операции чтения
Stomp::subscribe — Регистрирует подписку на указанную рассылку
Stomp::unsubscribe — Удаляет существующую подписку

Нашли ошибку?

Инструкция • Исправление • Сообщение об ошибке

+Добавить

Примечания пользователей 1 note

down

guilherme dot geronimo at gmail dot com ¶

9 years ago

In some cases (E.g. ActiveMQ), when you have many consumers you need to identify your "client-id" during the connection process, otherwise the server can misunderstand your connection and create new topics/queues:
<?php
$stomp = new Stomp($url, $user, $password, array('client-id'=> $clientId ));
?>

+Добавить