rocketmq_common::common::message::message_decoder

Function decodes_batch

Source 
pub fn decodes_batch(
    byte_buffer: &mut Bytes,
    read_body: bool,
    decompress_body: bool,
) -> Vec<MessageExt>