Struct dove::container::Session

pub struct Session { /* fields omitted */ }

Represents an AMQP session.

Implementations

impl Session

pub async fn new_sender(&self, address: &str) -> Result<Sender>

Create a new sender link for a given address cross this session. The sender is returned when the other side have confirmed its existence.

pub async fn new_sender_with_options(
    &self,
    address: &str,
    options: impl Into<SenderOptions>
) -> Result<Sender>

Create a new sender link for a given address cross this session. The sender is returned when the other side have confirmed its existence.

pub async fn new_receiver(&self, address: &str) -> Result<Receiver>

Create a new receiving link for a given address cross this session. The is returned when the other side have confirmed its existence.

pub async fn new_receiver_with_options(
    &self,
    address: &str,
    options: impl Into<ReceiverOptions>
) -> Result<Receiver>

Create a new receiving link for a given address cross this session. The is returned when the other side have confirmed its existence.

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

Close a session, ending the end performative.

Trait Implementations

impl Drop for Session

fn drop(&mut self)

Executes the destructor for this type.