Struct lapin_async::queue::Queue

pub struct Queue {
    pub name: String,
    pub bindings: HashMap<(String, String), Binding>,
    pub consumers: HashMap<String, Consumer>,
    pub message_count: u32,
    pub consumer_count: u32,
    pub get_messages: VecDeque<BasicGetMessage>,
    pub current_get_message: Option<BasicGetMessage>,
}

Fields

name: String

bindings: HashMap<(String, String), Binding>

consumers: HashMap<String, Consumer>

message_count: u32

consumer_count: u32

get_messages: VecDeque<BasicGetMessage>

current_get_message: Option<BasicGetMessage>

Methods

impl Queue

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

pub fn next_basic_get_message(&mut self) -> Option<BasicGetMessage>

Trait Implementations

impl Debug for Queue

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

Formats the value using the given formatter.