Struct AsyncEventbusRabbitMQ 

pub struct AsyncEventbusRabbitMQ { /* private fields */ }

Implementations

impl AsyncEventbusRabbitMQ

pub fn new(config: Config, qos_config: QoSConfig) -> Self

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

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

pub async fn subscribe<F, Fut>( &self, exchange_name: &str, routing_key: &str, handler: F, process_timeout: Option<Duration>, command_timeout: Option<Duration>, ) -> Result<(), AppError>

where F: Fn(Message) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), Box<dyn StdError + Send + Sync>>> + Send + 'static,

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: Option<DeliveryMode>, expiration: Option<u32>, ) -> Result<Vec<u8>, AppError>

pub async fn provide_resource<F, Fut>( &self, routing_key: &str, handler: F, process_timeout: Option<Duration>, command_timeout: Option<Duration>, ) -> Result<(), AppError>

where F: Fn(Message) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Message, Box<dyn StdError + Send + Sync>>> + Send + 'static,

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

Trait Implementations

impl Clone for AsyncEventbusRabbitMQ

fn clone(&self) -> AsyncEventbusRabbitMQ

Returns a duplicate of the value.

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

Performs copy-assignment from source.