Skip to main content

Module queue

Module queue 

Source
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:

  • QueueConsumer trait:业务侧实现消息处理逻辑
  • QueueRuntime:管理 consumer lifecycle(启动 / 停止 / 监听 cancel)

§设计

sz-orm-queue 的 MessageQueue trait 只提供原子操作(publish/consume/ack), 没有 consumer loop helper。本模块补充该能力,配合 CancellationToken 做退出。

Structs§

QueueRuntime
队列运行时
QueueRuntimeConfig
队列运行时配置

Enums§

QueueConsumerError
队列消费者错误

Traits§

QueueConsumer
队列消费者 trait