Expand description
sz-orm-queue 消费者接入
§PHP 对齐
对齐 PHP think-queue 的消费者模型:
// think-queue 的 worker 模型
$worker->runNextJob($connection, $queue, $delay, $sleep, $tries);Rust 端复用 sz-orm-queue::MessageQueue trait,提供 consumer loop helper:
QueueConsumertrait:业务侧实现消息处理逻辑QueueRuntime:管理 consumer lifecycle(启动 / 停止 / 监听 cancel)
§设计
sz-orm-queue 的 MessageQueue trait 只提供原子操作(publish/consume/ack),
没有 consumer loop helper。本模块补充该能力,配合 CancellationToken 做退出。
Structs§
- Queue
Runtime - 队列运行时
- Queue
Runtime Config - 队列运行时配置
Enums§
- Queue
Consumer Error - 队列消费者错误
Traits§
- Queue
Consumer - 队列消费者 trait