Skip to main content

wae_queue/
lib.rs

1//! WAE Queue - 消息队列抽象层
2//!
3//! 提供统一的消息队列能力抽象，支持多种消息队列后端。
4//!
5//! 深度融合 tokio 运行时，所有 API 都是异步优先设计。
6//! 微服务架构友好，支持消息确认、重试、延迟队列等特性。
7
8#![warn(missing_docs)]
9
10use std::time::Duration;
11
12// 模块声明
13mod backends;
14mod consumers;
15mod producers;
16mod services;
17mod types;
18
19// 重新导出所有公共类型和结构体
20pub use backends::memory::*;
21pub use consumers::{ConsumerBackend, MessageConsumer};
22pub use producers::{MessageProducer, ProducerBackend};
23pub use services::{QueueManager, QueueService};
24pub use types::*;
25pub use wae_types::{WaeError, WaeResult};
26
27#[cfg(feature = "redis-backend")]
28pub use backends::redis::*;
29
30#[cfg(feature = "kafka-backend")]
31pub use backends::kafka::*;
32
33/// 便捷函数：创建内存队列服务
34pub fn memory_queue_service() -> MemoryQueueService {
35    MemoryQueueService::new()
36}