Struct lapin_async::queues::Queues

pub struct Queues { /* fields omitted */ }

Methods

impl Queues

pub fn register(&self, queue: Queue)

pub fn deregister(&self, queue: &str)

pub fn register_consumer(
    &self,
    queue: &str,
    consumer_tag: String,
    consumer: Consumer
)

pub fn deregister_consumer(&self, consumer_tag: &str)

pub fn drop_prefetched_messages(&self)

pub fn get_stats(&self, queue: &str) -> QueueStats

pub fn get_basic_get_message(
    &self,
    queue: &str,
    request_id: RequestId
) -> Option<BasicGetMessage>

pub fn start_consumer_delivery(
    &self,
    consumer_tag: &str,
    message: Delivery
) -> Option<String>

pub fn start_basic_get_delivery(&self, queue: &str, message: BasicGetMessage)

pub fn handle_content_header_frame(
    &self,
    queue: &str,
    request_id_or_consumer_tag: Either<RequestId, String>,
    size: u64,
    properties: BasicProperties
)

pub fn handle_body_frame(
    &self,
    queue: &str,
    request_id_or_consumer_tag: Either<RequestId, String>,
    remaining_size: usize,
    payload_size: usize,
    payload: Vec<u8>
)

Trait Implementations

impl Default for Queues

fn default() -> Queues

Returns the "default value" for a type.

impl Clone for Queues

fn clone(&self) -> Queues

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Queues

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

Formats the value using the given formatter.