Stomp protocol utils

Набор классов-утилит для взаимодействия с брокетами сообщений (ActiveMQ, RabbitMQ, ZeroMQ и т.д.) по протоколу Stomp. Пакет решает две наиболее распространенные задачи: - Отправка сообщения в очередь; - Получение сообщений из очеред в режиме демона. Логирование можно осуществлять путем подключения любого PSR-совместимого логгера., _(*1)

Requirements

php 7.x, _(*2)

Установка

Для установки пакета с использованием composer:, _(*3)

composer require stomp-utils

Использование

Отправка сообщения в очередь

Publisher::send(string $destination, string $body[, array $headers]) - отправляет сообщение в очередь. Параметры: - $destination - Название очереди, куда отправлять сообщение; - $body - тело сообщения; - $headers - массив заголовков сообщения., _(*4)

Получение сообщений из очереди в режиме демона

Для начала необходимо реализовать класс, который будет обрабатывать полученное сообщение. Он должен наследоваться от класса Tochka\Integration\Stomp\BaseWorker и реализовывать метод handle(). Далее необходимо реализовать класс, который будет слушать сообщения из очереди. Класс должен наследоваться от Tochka\Integration\Stomp\Listener. В классе нужно переопределить метод generateHandler(), который должен возвращать объект-обработчик сообщения, который должен являться экземпляром Tochka\Integration\Stomp\BaseWorker., _(*5)