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
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.