Struct lapin_futures::Client

pub struct Client { /* fields omitted */ }

Connect to a server and create channels

Methods

impl Client

pub fn connect(uri: &str, options: ConnectionProperties) -> ClientFuture

Connect to an AMQP Server

pub fn connect_uri(uri: AMQPUri, options: ConnectionProperties) -> ClientFuture

Connect to an AMQP Server

pub fn create_channel(
    &self
) -> impl Future<Item = Channel, Error = Error> + Send + 'static

Return a future that resolves to a Channel once the method succeeds

pub fn update_secret(&self, new_secret: &str, reason: &str) -> Confirmation<()>

Update the secret used by some authentication module such as oauth2

pub fn block(&self, reason: &str) -> Confirmation<()>

Block all consumers and publishers on this connection

pub fn unblock(&self) -> Confirmation<()>

Unblock all consumers and publishers on this connection

pub fn on_error<E: Fn() + Send + 'static>(&self, handler: Box<E>)

Register an error handler which will be called when connection reaches an Error state

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.