5 releases (3 breaking)
Uses old Rust 2015
0.4.1 | Dec 15, 2017 |
---|---|
0.4.0 |
|
0.3.1 | Nov 14, 2017 |
0.2.0 | Oct 23, 2017 |
0.1.0 | Sep 30, 2017 |
#44 in #rabbitmq
31 downloads per month
Used in amqpr
41KB
913 lines
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
use amqpr_api::handshake::{start_handshake, SimpleHandshaker};
use tokio_core::reactor::Core;
use tokio_core::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())
.map_err(|e| Error::from(e))
.and_then(move |socket| start_handshake(handshaker, socket));
let socket = core.run(future).unwrap();
lib.rs
:
amqpr-api is AMQP client api library. You can talk with AMQP server via channel controller provided by this crate. There is two kind of channel controllers; GlobalChannelController and LocalChannelController.
Dependencies
~10MB
~168K SLoC