[−][src]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 Definitions
Error | |
Result |