README

用于处理 Stomp 协议队列的类。PHP Stomp 扩展的包装器。

用途是什么？

当服务器端连接中断或发生任何连接问题时，此适配器会自动重新建立连接（同时安全地断开旧连接）并恢复所有活跃的订阅。
支持 Stomp 1.2。
这样更方便

$stomp = new \Tochka\Esb\Stomp\StompAdapter($url, $login, $password);

// Отправка сообщения
$stomp->send('queue_1', 'Data');

// Подписываемся сразу на несколько очередей
$stomp->subscribe('queue_1');
$stomp->subscribe('queue_2');

// Ждем сообщений
while (true) {
    // Каждые две секунды проверяем, есть ли сообщения
    sleep(2);
    
    while ($frame = $stomp->getNextMessage()) {
        // Что-нибудь делаем с сообщением
        // ...
        
        // Отвечает серверу, что все ок
        $stomp->ack($frame);
        // или что-то пошло не так
        // $stomp->nack($frame);
    }
}

当对象被销毁时，它会自动取消所有活跃的订阅并关闭连接

tochka-developers / stomp-adapter

维护者

详细信息

README