Клас 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— Видаляє існуючу передплату