Struct lapin_async::queue::Queue

pub struct Queue {
    pub name: String,
    pub consumers: HashMap<String, Consumer>,
    pub stats: QueueStats,
    // some fields omitted
}

Fields

name: String

consumers: HashMap<String, Consumer>

stats: QueueStats

Methods

impl Queue

pub fn new(name: String, message_count: u32, consumer_count: u32) -> Queue

pub fn get_basic_get_message(
    &mut self,
    request_id: RequestId
) -> Option<BasicGetMessage>

pub fn drop_prefetched_messages(&mut self)

pub fn start_new_delivery(&mut self, delivery: BasicGetMessage)

pub fn set_delivery_properties(&mut self, properties: BasicProperties)

pub fn receive_delivery_content(&mut self, payload: Vec<u8>)

pub fn new_delivery_complete(&mut self, request_id: RequestId)

Trait Implementations

impl Debug for Queue

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

Formats the value using the given formatter.