Struct lapin_async::connection::Connection

pub struct Connection {
    pub configuration: Configuration,
    pub status: ConnectionStatus,
    // some fields omitted
}

Fields

configuration: Configuration

status: ConnectionStatus

Methods

impl Connection

pub fn create_channel(&self) -> Result<Channel, Error>

pub fn set_vhost(&self, vhost: &str)

pub fn send_frame(
    &self,
    channel_id: u16,
    priority: Priority,
    frame: AMQPFrame,
    expected_reply: Option<Reply>
) -> Result<Wait<()>, Error>

pub fn next_expected_reply(&self, channel_id: u16) -> Option<Reply>

pub fn next_frame(&self) -> Option<(SendId, AMQPFrame)>

next message to send to the network

returns None if there's no message to send

pub fn handle_frame(&self, f: AMQPFrame) -> Result<(), Error>

updates the current state with a new received frame

pub fn send_heartbeat(&self) -> Result<(), Error>

pub fn mark_sent(&self, send_id: SendId)

pub fn remove_channel(&self, channel_id: u16) -> Result<(), Error>

pub fn set_closing(&self)

pub fn set_closed(&self) -> Result<(), Error>

pub fn set_error(&self) -> Result<(), Error>

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