Struct SendCommandHandler 

pub struct SendCommandHandler { /* private fields */ }

Handles message sending commands for single and multiple message operations.

Provides functionality for sending messages to Service Bus queues using the producer manager. Supports both single message sends and batch sending operations with comprehensive error handling and statistics tracking.

Examples

use quetty_server::service_bus_manager::command_handlers::SendCommandHandler;

let handler = SendCommandHandler::new(producer_manager);

// Send a single message
let response = handler.handle_send_message(
    "target-queue".to_string(),
    message_data
).await?;

// Send multiple messages
let response = handler.handle_send_messages(
    "target-queue".to_string(),
    vec![message1, message2, message3]
).await?;

Implementations

impl SendCommandHandler

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

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

pub async fn handle_send_messages( &self, queue_name: String, messages: Vec<MessageData>, ) -> Result<ServiceBusResponse, ServiceBusError>