tochka-developers / stomp-adapter
Stomp protocol utils set
Installs: 6 937
Dependents: 0
Suggesters: 0
Security: 0
Stars: 0
Watchers: 4
Forks: 0
Open Issues: 0
Type:package
Requires
- php: >=5.6
- ext-stomp: *
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); } }
- При уничтожении объекта сам отписывается от всех активных подписок и закрывает соединение