Struct AmqpConnection

pub struct AmqpConnection { /* private fields */ }

Manages an AMQP connection.

Implementations

impl AmqpConnection

pub fn new(opts: AmqpConnectionOptions) -> Result<AmqpConnection, String>

Create a connection instance.

Trait Implementations

impl Clone for AmqpConnection

fn clone(&self) -> AmqpConnection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl GmqConnection for AmqpConnection

fn status(&self) -> Status

To get the connection status.

fn add_handler(&mut self, handler: Arc<dyn EventHandler>) -> String

To add a connection event handler. This will return an identifier for applications to manage handlers.

fn remove_handler(&mut self, id: &str)

To remove a handler with an idenfier from GmqConnection::add_handler.

fn connect(&mut self) -> Result<(), Box<dyn StdError>>

To connect to the message broker. The GmqConnection will connect to the broker using another runtime task and report status with Statuss.

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn StdError + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

To close the connection.