Crate sz_orm_queue 

SZ-ORM Queue — 消息队列

提供统一的消息队列抽象，内置 InMemory 实现，并支持 RabbitMQ、Kafka、NATS、 ActiveMQ、Pulsar、RocketMQ 等多种消息中间件 provider。

主要模块

• queue — 核心 trait 与统一封装
• rabbitmq / kafka / nats / activemq / pulsar / rocketmq — 各 provider 实现

Re-exports

pub use error::MqError;

pub use queue::ActiveConfig;

pub use queue::BackpressurePolicy;

pub use queue::InMemoryQueue;

pub use queue::KafkaConfig;

pub use queue::Message;

pub use queue::MessageQueue;

pub use queue::MqProvider;

pub use queue::NatsConfig;

pub use queue::OverflowStrategy;

pub use queue::PulsarConfig;

pub use queue::QueueConfig;

pub use queue::QueueWrapper;

pub use queue::RabbitConfig;

pub use queue::ReconnectPolicy;

pub use queue::ReconnectState;

pub use queue::RocketConfig;

pub use activemq::InMemoryActivemqQueue;

pub use kafka::InMemoryKafkaQueue;

pub use nats::InMemoryNatsQueue;

pub use pulsar::InMemoryPulsarQueue;

pub use rabbitmq::InMemoryRabbitmqQueue;

pub use rocketmq::InMemoryRocketmqQueue;

Modules

activemq

error

kafka

nats

pulsar

queue

rabbitmq

rocketmq