tochka-developers/stomp-utils

此软件包最新版本（v2.1.5）没有提供许可证信息。

Stomp 协议工具集

维护者

详细信息

github.com/tochka-developers/stomp-utils

源代码

问题

安装: 168

依赖项: 0

建议者: 0

安全: 0

星标: 1

观察者: 5

分支: 1

公开问题: 0

类型：软件包

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-09-13 15:53:48 UTC

README

一组用于通过 Stomp 协议（https://stomp.github.io/）与消息代理（ActiveMQ, RabbitMQ, ZeroMQ 等）交互的类。此软件包解决两个最常见的问题：

  • 将消息发送到队列；
  • 以守护进程模式从队列中获取消息。可以通过连接任何 PSR 兼容的日志记录器来执行日志记录。

要求

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 的实例。