Struct lapin_async::queues::Queues

pub struct Queues { /* fields omitted */ }

Methods

impl Queues

pub fn register(&self, queue: QueueState)

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

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

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

pub fn drop_prefetched_messages(&self)

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

pub fn start_basic_get_delivery(
    &self,
    queue: &str,
    message: BasicGetMessage,
    wait_handle: WaitHandle<Option<BasicGetMessage>>
)

pub fn handle_content_header_frame(
    &self,
    queue: &str,
    consumer_tag: Option<ShortString>,
    size: u64,
    properties: BasicProperties
)

pub fn handle_body_frame(
    &self,
    queue: &str,
    consumer_tag: Option<ShortString>,
    remaining_size: usize,
    payload_size: usize,
    payload: Vec<u8>
)

Trait Implementations

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 Default for Queues

fn default() -> Queues

Returns the "default value" for a type.

impl Debug for Queues

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

Formats the value using the given formatter.