Struct lapin_futures_tls_internal::lapin::client::Client

pub struct Client<T> {
    pub configuration: Configuration,
    // some fields omitted
}

the Client structures connects to a server and creates channels

Fields

configuration: Configuration

Methods

impl<T> Client<T> where
    T: 'static + Send + Sync + AsyncRead + AsyncWrite, 

pub fn connect(
    stream: T,
    options: ConnectionOptions
) -> impl Send + Future<Item = (Client<T>, Heartbeat<impl Send + Future<Item = (), Error = Error> + 'static>), Error = Error> + 'static

Takes a stream (TCP, TLS, unix socket, etc) and uses it to connect to an AMQP server.

This function returns a future that resolves once the connection handshake is done. The result is a tuple containing a Client that can be used to create Channels and a Heartbeat instance. The heartbeat is a task (it implements Future) that should be spawned independently of the other futures.

To stop the heartbeat task, see HeartbeatHandle.

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

creates a new channel

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

pub fn create_confirm_channel(
    &self,
    options: ConfirmSelectOptions
) -> impl Send + Future<Item = Channel<T>, Error = Error> + 'static

returns a future that resolves to a Channel once the method succeeds the channel will support RabbitMQ's confirm extension

Trait Implementations

impl<T> Clone for Client<T> where
    T: Send, 

fn clone(&self) -> Client<T>

Returns a copy of the value.

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

Performs copy-assignment from source.