Crate rocketmq_client
source · [−]Expand description
This crate provides APIs to publish messages to and subscribe messages from Apache RocketMQ. At the moment, it is still work-in-progress.
Modules
This module defines connection related structs.
Define client side errors.
Implement the classic length field based frame codec. Note specific frame are defined in the protocol module.
Define Message struct. Application data are enveloped in Message before publishing to Apache RocketMQ.
Define protocols used when talking to Apache RocketMQ servers.
Messaging are about publishing and subscribing messages. Publisher is the struct to utilize to deliver message to broker.
This module defines RouteManager to dynamically fetch and refresh routes for each topic in use.