Struct dove::container::Container

pub struct Container { /* fields omitted */ }

Represents an AMQP 1.0 container that can manage multiple connections.

Implementations

impl Container

pub fn new() -> Result<Container>

Creates a new container that can be used to connect to AMQP endpoints. use the start() method to launch a worker thread that handles the connection processing, or invoke the run() method.

pub fn with_id(container_id: &str) -> Result<Container>

pub fn start(self) -> Self

Start a worker thread to process connections for this container.

pub fn run(&self)

Process connections for this container.

pub async fn connect<S: ToSocketAddrs + Send + 'static>(
    &self,
    host: S,
    opts: ConnectionOptions
) -> Result<Connection>

Connect to an AMQP endpoint and send the initial open performative.

pub fn close(&mut self) -> Result<()>

Close the connection. Flushes outgoing buffer before sending the final close performative, and closing the connection.

pub fn container_id(&self) -> &str

Trait Implementations

impl Drop for Container

fn drop(&mut self)

Executes the destructor for this type.