tochka-developers/stomp-utils

There is no license information available for the latest version (v2.1.5) of this package.

Stomp protocol utils set

Maintainers

Details

github.com/tochka-developers/stomp-utils

Source

Issues

Installs: 168

Dependents: 0

Suggesters: 0

Security: 0

Stars: 1

Watchers: 5

Forks: 1

Open Issues: 0

Type:package

v2.1.5 2019-05-13 04:19 UTC

Requires

Unknown License 781c3793cd4040652cfbb9d49aebff148bb2fde9

  • Ivanov Sergey <ivanov.woop@tochka.com>

This package is auto-updated.

Last update: 2024-11-13 16:08:42 UTC

README

Набор классов-утилит для взаимодействия с брокетами сообщений (ActiveMQ, RabbitMQ, ZeroMQ и т.д.) по протоколу Stomp. Пакет решает две наиболее распространенные задачи:

  • Отправка сообщения в очередь;
  • Получение сообщений из очеред в режиме демона. Логирование можно осуществлять путем подключения любого PSR-совместимого логгера.

Requirements

php 7.x

Установка

Для установки пакета с использованием composer:

composer require stomp-utils

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

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

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

  • $destination - Название очереди, куда отправлять сообщение;
  • $body - тело сообщения;
  • $headers - массив заголовков сообщения.

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

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