Expand description
WAE Queue - 消息队列抽象层
提供统一的消息队列能力抽象，支持多种消息队列后端。
深度融合 tokio 运行时，所有 API 都是异步优先设计。 微服务架构友好，支持消息确认、重试、延迟队列等特性。
Structs§
- Consumer
Config - 消费者配置
- Memory
Consumer Backend - 内存消费者后端
- Memory
Producer Backend - 内存生产者后端
- Memory
Queue Manager - 内存队列管理器
- Memory
Queue Service - 内存队列服务
- Message
- 消息封装 (泛型)
- Message
Consumer - 消息消费者 (提供泛型封装)
- Message
Metadata - 消息元数据
- Message
Producer - 消息生产者 (提供泛型封装)
- Producer
Config - 生产者配置
- Queue
Config - 队列配置
- RawMessage
- 原始消息 (字节形式)
- Received
Message - 接收到的消息 (泛型)
- Received
RawMessage - 接收到的原始消息 (带确认能力)
- WaeError
- 中心化错误类型
Traits§
- Consumer
Backend - 消息消费者后端 trait (dyn 兼容)
- Producer
Backend - 消息生产者后端 trait (dyn 兼容)
- Queue
Manager - 队列管理 trait
- Queue
Service - 消息队列服务 trait
Functions§
- memory_
queue_ service - 便捷函数：创建内存队列服务