Crate rocketmq[][src]

Re-exports

pub use consumer::ConsumerOptions;
pub use message::Message;
pub use producer::Producer;
pub use producer::ProducerOptions;

Modules

consumer

RocketMQ consumer

message
producer

RocketMQ producer

resolver

RocketMQ name server resolver

Structs

PushConsumer

Enums

Error