Struct lapin_async::queue::Queue
[−]
[src]
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
[src]
pub fn new(name: String, message_count: u32, consumer_count: u32) -> Queue
[src]
pub fn next_delivery(&mut self, consumer_tag: &str) -> Option<Delivery>
[src]
pub fn next_basic_get_message(&mut self) -> Option<BasicGetMessage>
[src]
Trait Implementations
impl Clone for Queue
[src]
fn clone(&self) -> Queue
[src]
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Performs copy-assignment from source
. Read more
impl Debug for Queue
[src]
fn fmt(&self, __arg_0: &mut Formatter) -> Result
[src]
Formats the value using the given formatter. Read more