Crate rocketmq_protocol 

Runtime-neutral RocketMQ wire protocol contracts.

This crate defines request and response codes, RemotingCommand frames, custom-header codecs, protocol bodies, compression, and trace encoding. Its main entry points include RequestCode, RemotingCommand, CommandCustomHeader, HeaderCodec, and RpcRequestHeader.

Enable the simd feature to use accelerated protocol decoding paths.

Re-exports

pub use code::request_code::RequestCode;

pub use code::response_code::RemotingSysResponseCode;

pub use protocol::command_custom_header::CommandCustomHeader;

pub use protocol::command_custom_header::FromMap;

pub use protocol::command_custom_header::HeaderEncodeCapability;

pub use protocol::command_custom_header::HeaderMap;

pub use protocol::encoded_frame::EncodedFrame;

pub use protocol::encoded_frame::EncodedFrameHead;

pub use protocol::header_codec::HeaderCodec;

pub use protocol::remoting_command::RemotingCommand;

pub use protocol::rocketmq_serializable;

pub use rpc::rpc_request_header::RpcRequestHeader;

pub use rpc::topic_request_header::TopicRequestHeader;

Modules

code

Request and response codes used by the RocketMQ remoting protocol.

common

Compression codecs, message wire types, and shared wire constants.

protocol

rpc

trace

Trace records, transfer types, constants, and wire codecs.

version

Enums

ProtocolContractViolation

A deterministic RocketMQ protocol contract violation.