An fast, light, straightforward, high performance, stateless message queue, supporting both ConsumeMode
and BroadcastMode
, implemented using Rust and Tokio.
Assign tasks among multiple consumers (competitive consumer model)
A message will be consumed and processed by multiple consumers separately.
- COMMAND: Type is uint8(fixed 1-byte), refer to Command Definition
- BODY_SIZE: Type is uint32(fixed 4-byte), Byte length of the body, [0, MAX_BODY_SIZE]
- BODY: Content of the command parameters
- CODE: Type is uint8(fixed 1-byte), refer to ECode Definition
- DATA_SIZE: Type is uint32(fixed 4-byte)
- DATA: Returned based on the command and status code (has a value for data_size > 0)