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ยง
- connection
- This module defines connection related structs.
- error
- Define client side errors.
- frame
- Implement the classic length field based frame codec. Note specific frame are defined in the protocol module.
- message
- Define Message struct. Application data are enveloped in
Messagebefore publishing to Apache RocketMQ. - protocol
- Define protocols used when talking to Apache RocketMQ servers.
- publisher
- Messaging are about publishing and subscribing messages.
Publisheris the struct to utilize to deliver message to broker. - route
- This module defines RouteManager to dynamically fetch and refresh routes for each topic in use.