wae-queue 0.0.2

WAE Queue - 消息队列抽象层，支持内存队列、Redis 和 RabbitMQ
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

//! 队列管理和服务实现

use super::{WaeResult, consumers::MessageConsumer, producers::MessageProducer, types::*};

/// 队列管理 trait
#[async_trait::async_trait]
pub trait QueueManager: Send + Sync {
    /// 声明队列
    async fn declare_queue(&self, config: &QueueConfig) -> WaeResult<()>;

    /// 删除队列
    async fn delete_queue(&self, name: &str) -> WaeResult<()>;

    /// 检查队列是否存在
    async fn queue_exists(&self, name: &str) -> WaeResult<bool>;

    /// 获取队列消息数量
    async fn queue_message_count(&self, name: &str) -> WaeResult<u64>;

    /// 清空队列
    async fn purge_queue(&self, name: &str) -> WaeResult<u64>;
}

/// 消息队列服务 trait

pub trait QueueService: Send + Sync {
    /// 创建生产者
    async fn create_producer(&self, config: ProducerConfig) -> WaeResult<MessageProducer>;

    /// 创建消费者
    async fn create_consumer(&self, config: ConsumerConfig) -> WaeResult<MessageConsumer>;

    /// 获取队列管理器
    fn manager(&self) -> &dyn QueueManager;

    /// 关闭连接
    async fn close(&self) -> WaeResult<()>;
}