Struct Consumer 

pub struct Consumer {
    pub name: String,
    pub queue: Queue,
    pub count_popped: u32,
    pub id: u32,
    pub header: Header,
    /* private fields */
}

Fields

name: String

queue: Queue

count_popped: u32

id: u32

header: Header

Implementations

impl Consumer

pub fn new( base_path: &str, consumer_name: &str, queue_name: &str, ) -> Result<Consumer, ErrorQueue>

pub fn new_with_mode( base_path: &str, consumer_name: &str, queue_name: &str, mode: Mode, ) -> Result<Consumer, ErrorQueue>

pub fn get_batch_size(&mut self) -> u32

pub fn open(&mut self, is_new: bool) -> bool

pub fn get_info(&mut self) -> bool

pub fn pop_header(&mut self) -> bool

pub fn go_to_next_part(&mut self) -> bool

pub fn seek_next_pos(&mut self) -> bool

pub fn pop_body(&mut self, msg: &mut [u8]) -> Result<usize, ErrorQueue>

pub fn commit(&mut self) -> bool

Trait Implementations

impl Drop for Consumer

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.