amqpr-api

A tokio future based amqp api library.

This library provides low lovel api. I recommend you to use amqpr library instead.

Examples

Establish connection

```rust use amqprapi::handshake::{starthandshake, SimpleHandshaker}; use tokiocore::reactor::Core; use tokiocore::net::TcpStream;

let mut core = Core::new().unwrap();

let handshaker = SimpleHandshaker { user: "guest".into(), pass: "guest".into(), virtual_host: "/".into(), };

let future = TcpStream::connect(&"127.0.0.1:5672".parse().unwrap(), &core.handle()) .maperr(|e| Error::from(e)) .andthen(move |socket| start_handshake(handshaker, socket));

let socket = core.run(future).unwrap(); ```