Struct QueueRuntime 

pub struct QueueRuntime { /* private fields */ }

队列运行时

管理 consumer lifecycle：启动一个消费循环任务，监听 CancellationToken 优雅退出。

设计

• 不持有 JoinHandle：消费任务由调用方持有，本结构仅提供启动入口
• ack 策略：handler 返回 Ok 时自动 ack；Err 时不 ack（消息留在 in_flight）
• 退出策略：监听 token.cancelled()，当前正在处理的消息会等待完成

用法

use sz_rust_core::runtime::queue::{QueueRuntime, QueueRuntimeConfig, QueueConsumer};
use sz_orm_queue::{InMemoryQueue, MessageQueue, Message};
use async_trait::async_trait;
use std::sync::Arc;
use tokio_util::sync::CancellationToken;

struct MyConsumer;
#[async_trait]
impl QueueConsumer for MyConsumer {
    async fn handle(&self, msg: &Message) -> Result<(), QueueConsumerError> {
        println!("got: {:?}", msg.payload);
        Ok(())
    }
}

let queue = Arc::new(InMemoryQueue::new(1000));
let runtime = QueueRuntime::new(
    QueueRuntimeConfig::new("orders"),
    queue,
);
let token = CancellationToken::new();
let handle = runtime.start(Arc::new(MyConsumer), token.clone());
// ... 业务运行 ...
token.cancel();
let _ = handle.await;

Implementations

impl QueueRuntime

pub fn new(config: QueueRuntimeConfig, queue: Arc<dyn MessageQueue>) -> Self

创建队列运行时

pub fn start<C>( &self, consumer: Arc<C>, token: CancellationToken, ) -> JoinHandle<()>

where C: QueueConsumer + 'static,

启动消费循环（返回 JoinHandle，调用方持有以控制 lifecycle）

行为

1. 每 poll_interval_ms 毫秒调用 queue.consume(topic) 拉取消息
2. 收到消息后调用 consumer.handle(&msg)
3. handler 返回 Ok → 自动 queue.ack(msg.id)
4. handler 返回 Err → 跳过 ack（消息留在 in_flight）
5. 监听 token.cancelled()，收到信号后停止拉取新消息

pub fn topic(&self) -> &str

获取主题

pub fn config(&self) -> &QueueRuntimeConfig

获取配置