Crate ironmq_client 

Client of ironmq.

Usage

use ironmq_client::*;

async fn client() -> Result<()> {
    let conn = connect("127.0.0.1:5672".to_string()).await?;
    open(&conn, "/".into()).await?;
    channel_open(&conn, 1).await?;
    basic_publish(&conn, 1, "exchange", "routing", "Hello".into()).await?;
    close(&conn).await?;

    Ok(())
}

Modules

client

Macros

client_error

Structs

ClientError

Connection

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

Functions

basic_consume

basic_publish

channel_close

channel_open

close

connect

Connect to an AMQP server.

exchange_declare

open

queue_bind

queue_declare

Type Aliases

Error

Result