lapin 4.7.2

AMQP client library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use lapin::{Connection, ConnectionProperties, Result};

async fn tokio_main() -> Result<()> {
    let uri = "amqp://demo:demo@localhost:5673";
    let options = ConnectionProperties::default();
    let _connection = Connection::connect(uri, options).await?;
    Ok(())
}

#[tokio::test]
async fn connection() {
    let res = tokio_main().await;
    assert!(res.is_err());
    let err = res.unwrap_err();
    assert!(err.is_io_error());
    if let lapin::ErrorKind::IOError(e) = err.kind() {
        assert_eq!(e.kind(), std::io::ErrorKind::ConnectionRefused);
    } else {
        unreachable!();
    }
}