Struct RustRabbit 

pub struct RustRabbit { /* private fields */ }

Main facade for the rust-rabbit library

Implementations

impl RustRabbit

pub async fn new(config: RabbitConfig) -> Result<Self>

Create a new RustRabbit instance with the given configuration

pub async fn with_metrics( config: RabbitConfig, metrics: RustRabbitMetrics, ) -> Result<Self>

Create a new RustRabbit instance with metrics enabled

pub fn publisher(&self) -> Publisher

Get a publisher instance

pub async fn consumer(&self, options: ConsumerOptions) -> Result<Consumer>

Create a consumer with the given options

pub fn health_checker(&self) -> HealthChecker

Get the health checker

pub fn metrics(&self) -> Option<&RustRabbitMetrics>

Get the metrics instance if enabled

pub async fn create_batcher( &self, config: BatchConfig, ) -> Result<MessageBatcher>

Create a message batcher for high-throughput publishing

pub fn enable_shutdown_handling( &mut self, config: ShutdownConfig, ) -> Arc<ShutdownManager>

Enable graceful shutdown handling

pub fn shutdown_manager(&self) -> Option<Arc<ShutdownManager>>

Get the shutdown manager if enabled

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

Close all connections with optional graceful shutdown