Struct lapin_async::queue::Queue
[−]
[src]
pub struct Queue { pub name: String, pub passive: bool, pub durable: bool, pub exclusive: bool, pub auto_delete: bool, pub bindings: HashMap<(String, String), Binding>, pub consumers: HashMap<String, Consumer>, pub message_count: u32, pub consumer_count: u32, pub created: bool, pub get_messages: VecDeque<Message>, pub current_get_message: Option<Message>, }
Fields
name: String
passive: bool
durable: bool
exclusive: bool
auto_delete: bool
bindings: HashMap<(String, String), Binding>
consumers: HashMap<String, Consumer>
message_count: u32
consumer_count: u32
created: bool
get_messages: VecDeque<Message>
current_get_message: Option<Message>
Methods
impl Queue
[src]
fn new(
name: String,
passive: bool,
durable: bool,
exclusive: bool,
auto_delete: bool
) -> Queue
name: String,
passive: bool,
durable: bool,
exclusive: bool,
auto_delete: bool
) -> Queue
fn next_message(&mut self, consumer_tag: Option<&str>) -> Option<Message>
Trait Implementations
impl Clone for Queue
[src]
fn clone(&self) -> Queue
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0
Performs copy-assignment from source
. Read more