Struct dove::container::Connection

pub struct Connection {
    pub container_id: String,
    pub host: SocketAddr,
    pub channel_max: u16,
    pub idle_timeout: Duration,
    pub remote_idle_timeout: Duration,
    pub remote_container_id: String,
    pub remote_channel_max: u16,
    // some fields omitted
}

Represents a single AMQP connection to a remote endpoint.

Fields

container_id: String

host: SocketAddr

channel_max: u16

idle_timeout: Duration

remote_idle_timeout: Duration

remote_container_id: String

remote_channel_max: u16

Implementations

impl Connection

pub async fn new_session(&self, opts: Option<SessionOpts>) -> Result<Session>

Create a new session over this connection. Returns a session once the other endpoint have confirmed the creation.

pub fn close(&self, error: Option<ErrorCondition>) -> Result<()>

Close a connection, ending the close performative.

Trait Implementations

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.