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_with_identity(
    uri: &str,
    options: ConnectionProperties,
    identity: Identity
) -> ClientFuture

Connect to an AMQP Server

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

Connect to an AMQP Server

pub fn connect_uri_with_identity(
    uri: AMQPUri,
    options: ConnectionProperties,
    identity: Identity
) -> 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
) -> ConfirmationFuture<()>

Update the secret used by some authentication module such as oauth2

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

Block all consumers and publishers on this connection

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

Unblock all consumers and publishers on this connection

pub fn on_error<E: Fn(Error) + 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.