Struct metalmq_client::Client

pub struct Client { /* fields omitted */ }

Represents a connection to AMQP server. It is not a trait since async functions in a trait are not yet supported.

Implementations

impl Client

pub async fn open(&self, virtual_host: &str) -> Result<()>

Client "connects" to a virtual host. The virtual host may or may not exist, in case of an error we got a ClientError and the connection closes.

use metalmq_client::*;

async fn vhost(c: &Client) {
    if let Err(ce) = c.open("/invalid").await {
        eprintln!("Virtual host does not exist");
    }
}

pub async fn close(&self) -> Result<()>

pub async fn channel_open(&self, channel: u16) -> Result<()>

pub async fn channel_close(&self, channel: Channel) -> Result<()>

pub async fn exchange_declare(
    &self,
    channel: Channel,
    exchange_name: &str,
    exchange_type: &str,
    flags: Option<ExchangeDeclareFlags>
) -> Result<()>

pub async fn queue_bind(
    &self,
    channel: u16,
    queue_name: &str,
    exchange_name: &str,
    routing_key: &str
) -> Result<()>

pub async fn queue_declare(
    &self,
    channel: Channel,
    queue_name: &str
) -> Result<()>

pub async fn basic_consume(
    &self,
    channel: Channel,
    queue_name: &str,
    consumer_tag: &str,
    sink: MessageSink
) -> Result<()>

pub async fn basic_publish(
    &self,
    channel: Channel,
    exchange_name: &str,
    routing_key: &str,
    payload: String
) -> Result<()>