Struct MqCommand 

pub struct MqCommand {
    pub req_code: i16,
    pub l_flag: i8,
    pub v_flag: i16,
    pub opaque: i32,
    pub request_flag: i32,
    pub r_len: i32,
    pub r_body: Vec<u8>,
    pub e_len: i32,
    pub e_body: Vec<u8>,
    pub body: Vec<u8>,
    pub header_serialize_method: u8,
}

Fields

req_code: i16

l_flag: i8

v_flag: i16

for rust ,it always 7, means other language

opaque: i32

request_flag: i32

r_len: i32

r_body: Vec<u8>

e_len: i32

e_body: Vec<u8>

body: Vec<u8>

header_serialize_method: u8

Implementations

impl MqCommand

pub fn new() -> MqCommand

pub fn new_with_body( req_code: i16, r_body: Vec<u8>, e_body: Vec<u8>, body: Vec<u8>, ) -> MqCommand

pub async fn read_from_stream_with_opaque( broker_stream: &mut TcpStream, opaque: i32, ) -> Self

pub async fn read_from_stream(stream: &mut TcpStream) -> Self

pub async fn read_from_read_half(stream: &mut OwnedReadHalf) -> Option<Self>

pub fn to_bytes(&self) -> Vec<u8>

convert a command to bytes

pub fn convert_bytes_to_mq_command(bytes: Vec<u8>) -> MqCommand

pub fn convert_extend_header_to_json(&self) -> String

Trait Implementations

impl Debug for MqCommand

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.