Struct lapin_async::queue::Queue

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,
}

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

Methods

impl Queue

fn new(name: String,
       passive: bool,
       durable: bool,
       exclusive: bool,
       auto_delete: bool)
       -> Queue

fn next_message(&mut self, consumer_tag: &str) -> Option<Message>

Trait Implementations

impl Clone for Queue

fn clone(&self) -> Queue

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Queue

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

Formats the value using the given formatter.

impl PartialEq for Queue

fn eq(&self, __arg_0: &Queue) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, __arg_0: &Queue) -> bool

This method tests for !=.