Trait lapin_futures_tls_api::AMQPConnectionExt
[−]
[src]
pub trait AMQPConnectionExt { fn connect<C: TlsConnector + 'static, F: FnOnce(Error) + 'static>(
&self,
handle: Handle,
heartbeat_error_handler: F
) -> Box<Future<Item = Client<AMQPStream>, Error = Error> + 'static>; }
Add a connect method providing a lapin_futures::client::Client
wrapped in a Future
.
Required Methods
fn connect<C: TlsConnector + 'static, F: FnOnce(Error) + 'static>(
&self,
handle: Handle,
heartbeat_error_handler: F
) -> Box<Future<Item = Client<AMQPStream>, Error = Error> + 'static>
&self,
handle: Handle,
heartbeat_error_handler: F
) -> Box<Future<Item = Client<AMQPStream>, Error = Error> + 'static>
Method providing a lapin_futures::client::Client
wrapped in a Future
using a tokio_code::reactor::Handle
.