amqpr-api

基于 tokio future 的 amqp API 库。

此库提供低级 API。建议您使用 amqpr 库。

示例

建立连接

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 是 AMQP 客户端 API 库。您可以通过此 crate 提供的通道控制器与 AMQP 服务器进行通信。有两种类型的通道控制器；全局通道控制器和本地通道控制器。