Struct AsyncConnection 

pub struct AsyncConnection { /* private fields */ }

Implementations

impl AsyncConnection

pub fn new( config: Arc<Config>, publisher_confirms: Confirmations, auto_ack: bool, prefetch_count: Option<u16>, ) -> Self

pub async fn publish( &self, exchange_name: &str, routing_key: &str, body: impl Into<Vec<u8>>, content_type: &str, content_encoding: ContentEncoding, command_timeout: Option<Duration>, delivery_mode: DeliveryMode, expiration: Option<u32>, ) -> Result<(), AppError>

pub async fn subscribe( &self, handler: Handler, routing_key: &str, exchange_name: &str, exchange_type: &str, queue_name: &str, process_timeout: Option<Duration>, timeout_duration: Option<Duration>, queue_options: QueueOptions, ) -> Result<(), AppError>

pub async fn rpc_server( &self, handler: RPCHandler, routing_key: &str, exchange_name: &str, exchange_type: &str, queue_name: &str, response_timeout: Option<Duration>, timeout_duration: Option<Duration>, queue_options: QueueOptions, ) -> Result<(), AppError>

pub async fn rpc_client( &self, exchange_name: &str, routing_key: &str, body: impl Into<Vec<u8>>, content_type: &str, content_encoding: ContentEncoding, response_timeout_millis: u32, command_timeout: Option<Duration>, delivery_mode: DeliveryMode, expiration: Option<u32>, ) -> Result<Vec<u8>, AppError>

pub async fn update_secret( &self, new_secret: &str, reason: &str, command_timeout: Option<Duration>, ) -> Result<(), AppError>

pub async fn close(&self) -> Result<(), Box<dyn Error>>

Trait Implementations

impl Clone for AsyncConnection

fn clone(&self) -> AsyncConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.