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