Клас Stomp
(PECL stomp >= 0.1.0)
Вступ
Представляє зв'язок між PHP та Stomp сумісним брокером повідомлень (Message Broker).
Огляд класів
class Stomp
{
/* Методы */
public __construct( string $broker = ini_get("stomp.default_broker_uri"), string $username = ?, string $password = ?, array $headers = ?)
public abort(string $transaction_id, array $headers = ?): bool
stomp_abort(resource $link, string $transaction_id, array $headers = ?): bool
public ack(mixed $msg, array $headers = ?): bool
stomp_ack(resource $link, mixed $msg, array $headers = ?): bool
public begin(string $transaction_id, array $headers = ?): bool
stomp_begin(resource $link, string $transaction_id, array $headers = ?): bool
public commit(string $transaction_id, array $headers = ?): bool
stomp_commit(resource $link, string $transaction_id, array $headers = ?): bool
stomp_connect( string $broker = ini_get("stomp.default_broker_uri"), string $username = ?, string $password = ?, array $headers = ?): resource
stomp_close(resource $link): bool
public error(): string
stomp_error(resource $link): string
public getReadTimeout(): array
stomp_get_read_timeout(resource $link): array
public getSessionId(): string|false
stomp_get_session_id(resource $link): string|false
public hasFrame(): bool
stomp_has_frame(resource $link): bool
public readFrame(string $class_name = "stompFrame"): stompframe
stomp_read_frame(resource $link): array
public send(string $destination, mixed $msg, array $headers = ?): bool
stomp_send( resource $link, string $destination, mixed $msg, array $headers = ?): bool
public setReadTimeout(int $seconds, int $microseconds = ?): void
stomp_set_read_timeout(resource $link, int $seconds, int $microseconds = ?): void
public subscribe(string $destination, array $headers = ?): bool
stomp_subscribe(resource $link, string $destination, array $headers = ?): bool
public unsubscribe(string $destination, array $headers = ?): bool
stomp_unsubscribe(resource $link, string $destination, array $headers = ?): bool
public __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— Видаляє існуючу передплату