Crate lapin_futures_tls_api

lapin-futures-tls-api

This library offers a nice integration of tls-api with the lapin-futures library. It uses amq-protocol URI parsing feature and adds the connect and connect_cancellable methods to AMQPUri which will provide you with a lapin_futures::client::Client and optionally a lapin_futures::client::HeartbeatHandle wrapped in a Future.

It autodetects whether you’re using amqp or amqps and opens either a raw TcpStream or a TlsStream using tls-api as the SSL api.

Connecting and opening a channel

extern crate env_logger;
extern crate futures;
extern crate lapin_futures_tls_api;
extern crate tls_api_stub;
extern crate tokio;

use lapin_futures_tls_api::lapin;

use futures::future::Future;
use lapin::channel::ConfirmSelectOptions;
use lapin_futures_tls_api::AMQPConnectionTlsApiExt;

fn main() {
    env_logger::init();

    tokio::run(
        "amqps://user:pass@host/vhost?heartbeat=10".connect_cancellable::<tls_api_stub::TlsConnector>(|err| {
            eprintln!("heartbeat error: {:?}", err);
        }).and_then(|(client, heartbeat_handle)| {
            println!("Connected!");
            client.create_confirm_channel(ConfirmSelectOptions::default()).map(|channel| (channel, heartbeat_handle))
        }).and_then(|(channel, heartbeat_handle)| {
            println!("Stopping heartbeat.");
            heartbeat_handle.stop();
            println!("Closing channel.");
            channel.close(200, "Bye")
        }).map_err(|err| {
            eprintln!("amqp error: {:?}", err);
        })
    );
}

Modules

lapin

Reexport of the lapin_futures crate

uri

Reexport of the uri module from the amq_protocol crate

Traits

AMQPConnectionTlsApiExt

Add a connect method providing a lapin_futures::client::Client wrapped in a Future.

Type Definitions

AMQPStream

Reexport of AMQPStream