Rust Events

目前这是一个在消息 API 上添加一层抽象的实验。本项目受到 Mass Transit 的启发：对底层消息架构的拓扑结构做出一些决定，使创建消息类型（"事件"）变得容易。

主要功能

多租户

每个事件可以可选地附加一个租户，它仅是一个任意字符串。消费者可以监听所有或特定租户的事件。

支持的后端

RabbitMQ

通过 lapin 支持 RabbitMQ。

目前您不能选择拓扑结构，但希望在某阶段我们能够添加自定义的方式。

Kafka

通过 rust-rdkafka 支持 Kafka。

其他

许可证

基于 MIT 许可证。

运行测试

由于是集成测试，禁用并行测试 RUST_LOG=info cargo test -- --nocapture --test-threads=1

lib.rs:

RabbitMQ 事件管理器的实现