Struct StatusCommandHandler 

pub struct StatusCommandHandler { /* private fields */ }

Handles status and health check commands for monitoring Service Bus connections.

Provides functionality for checking connection health, queue status, and overall system state. Monitors both consumer and producer managers to provide comprehensive status information.

Examples

use quetty_server::service_bus_manager::command_handlers::StatusCommandHandler;

let handler = StatusCommandHandler::new(consumer_manager, producer_manager);

// Check overall connection status
let response = handler.handle_get_connection_status().await?;

// Get basic queue statistics
let response = handler.handle_get_queue_stats(
    "orders".to_string()
).await?;

Implementations

impl StatusCommandHandler

pub fn new( consumer_manager: Arc<Mutex<ConsumerManager>>, producer_manager: Arc<Mutex<ProducerManager>>, ) -> Self

pub async fn handle_get_connection_status( &self, ) -> Result<ServiceBusResponse, ServiceBusError>

pub async fn handle_get_queue_stats( &self, queue_name: String, ) -> Result<ServiceBusResponse, ServiceBusError>