Struct lapin_async::queue::QueueState

pub struct QueueState {
    pub name: ShortString,
    pub consumers: HashMap<ShortString, Consumer>,
    // some fields omitted
}

Fields

name: ShortString

consumers: HashMap<ShortString, Consumer>

Methods

impl QueueState

pub fn drop_prefetched_messages(&mut self)

pub fn start_new_delivery(
    &mut self,
    delivery: BasicGetMessage,
    wait_handle: WaitHandle<Option<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)

Trait Implementations

impl From<Queue> for QueueState

fn from(queue: Queue) -> Self

Performs the conversion.

impl Debug for QueueState

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

Formats the value using the given formatter.