Crate sz_orm_queue 

SZ-ORM Queue — Message Queue

Provides a unified message queue abstraction with built-in InMemory implementation, and supports RabbitMQ, Kafka, NATS, ActiveMQ, Pulsar, RocketMQ and other message middleware providers.

Main Modules

• queue — Core trait and unified wrapper
• rabbitmq / kafka / nats / activemq / pulsar / rocketmq — Each provider implementation

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