Struct metalmq_client::Client

pub struct Client {
    pub connection_id: String,
    pub event_stream: UnboundedReceiver<EventSignal>,
    /* private fields */
}

The AMQP client instance which reprensents an open connection.

Client can be created with Client::connect.

Usage

use metalmq_client::Client;

async fn connect() {
    let mut client = Client::connect("localhost:5672", "guest", "guest").await.unwrap();
    let mut channel = client.channel_open(1u16).await.unwrap();
    // ...
    channel.close().await.unwrap();
    client.close().await.unwrap();
}

Fields

connection_id: String

event_stream: UnboundedReceiver<EventSignal>

Implementations

impl Client

pub async fn connect(url: &str, username: &str, password: &str) -> Result<Client>

pub async fn channel_open(&mut self, channel: ChannelNumber) -> Result<Channel>

Open a channel in the current connection.

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

Closes the channel normally.

pub async fn receive_event(&mut self, timeout: Duration) -> Option<EventSignal>

Convenient function for listening EventSignal with timeout.