Struct v_queue::consumer::Consumer

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

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 seek_next_pos(&mut self) -> bool

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

pub fn commit(&mut self)

pub fn next(&mut self, commit: bool) -> bool

pub fn commit_and_next(&mut self) -> bool

Trait Implementations

impl Drop for Consumer

fn drop(&mut self)

Executes the destructor for this type.