Crate lapin_futures_native_tls
source ·Expand description
lapin-futures-native-tls
This library offers a nice integration of native-tls
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 native-tls
as the SSL engine.
Connecting and opening a channel
extern crate env_logger;
extern crate futures;
extern crate lapin_futures_native_tls;
extern crate tokio;
use lapin_futures_native_tls::{error, lapin};
use futures::future::Future;
use lapin::channel::ConfirmSelectOptions;
use lapin_futures_native_tls::AMQPConnectionNativeTlsExt;
fn main() {
env_logger::init();
tokio::run(
"amqps://user:pass@host/vhost?heartbeat=10".connect_cancellable(|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(|e| error::ErrorKind::ProtocolError(e).into())
}).map_err(|err| {
eprintln!("amqp error: {:?}", err);
})
);
}
Modules
Reexport of the
lapin_futures_tls_internal
errorsReexport of the
lapin_futures
crateReexport of the
uri
module from the amq_protocol
crateTraits
Add a connect method providing a
lapin_futures::client::Client
wrapped in a Future
.Type Definitions
Reexport of
AMQPStream