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

fn new(
    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

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 !=.