Crate metalmq_client[][src]

Expand description

Client of metalmq.

Examples

use metalmq_client::*;

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

    Ok(())
}

Modules

Module for helping BDD tests.

Macros

Shorthand for creating errors in async functions.

Structs

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

Represents a connection or channel error. If channel is None it is a connection error.

Message type for consuming messages.

Functions

Connect to an AMQP server.

Convenience function for setting up env_logger to see log messages.

Type Definitions

AMQP channel number

AMQP method class id

AMQP class id method id number

Interface for consuming messages.