Struct lapin_async::Connection

pub struct Connection { /* fields omitted */ }

Methods

impl Connection

pub fn connect(
    uri: &str,
    options: ConnectionProperties
) -> Confirmation<Connection>

Connect to an AMQP Server

pub fn connect_uri(
    uri: AMQPUri,
    options: ConnectionProperties
) -> Confirmation<Connection>

Connect to an AMQP Server

pub fn create_channel(&self) -> Confirmation<Channel>

pub fn configuration(&self) -> &Configuration

pub fn status(&self) -> &ConnectionStatus

pub fn close(&self, reply_code: ShortUInt, reply_text: &str) -> Confirmation<()>

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Connection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for Connection

fn default() -> Self

Returns the "default value" for a type.

impl Debug for Connection

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Evented for Connection

fn register(
    &self,
    poll: &Poll,
    token: Token,
    interest: Ready,
    opts: PollOpt
) -> Result<()>

Register self with the given Poll instance.

fn reregister(
    &self,
    poll: &Poll,
    token: Token,
    interest: Ready,
    opts: PollOpt
) -> Result<()>

Re-register self with the given Poll instance.

fn deregister(&self, poll: &Poll) -> Result<()>

Deregister self from the given Poll instance