Struct Client

pub struct Client<T> {
    pub configuration: Configuration,
    /* private fields */
}

the Client structures connects to a server and creates channels

Fields

configuration: Configuration

Implementations

impl<T> Client<T>

where T: AsyncRead + AsyncWrite + Send + Sync + 'static,

pub fn connect( stream: T, options: ConnectionOptions, ) -> impl Future<Item = (Client<T>, Heartbeat<impl Future<Item = (), Error = Error> + Send + 'static>), Error = Error> + Send + '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 Future<Item = Channel<T>, Error = Error> + Send + '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 Future<Item = Channel<T>, Error = Error> + Send + '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 duplicate of the value.

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

Performs copy-assignment from source.