Struct ConsumerManager

pub struct ConsumerManager { /* private fields */ }

Implementations

impl ConsumerManager

pub fn new( service_bus_client: Arc<Mutex<ServiceBusClient<BasicRetryPolicy>>>, batch_config: BatchConfig, ) -> Self

pub async fn switch_queue( &mut self, queue_info: QueueInfo, ) -> ServiceBusResult<()>

Switch to a different queue, disposing current consumer if needed

pub fn current_queue(&self) -> Option<&QueueInfo>

Get current queue information

pub fn is_consumer_ready(&self) -> bool

Check if consumer is available and ready

pub async fn peek_messages( &self, max_count: u32, from_sequence: Option<i64>, ) -> ServiceBusResult<Vec<MessageModel>>

Peek messages from the current queue

pub async fn receive_messages( &self, max_count: u32, ) -> ServiceBusResult<Vec<ServiceBusReceivedMessage>>

Receive messages from the current queue (for processing)

pub async fn complete_message( &self, message: &ServiceBusReceivedMessage, ) -> ServiceBusResult<()>

Complete a single message

pub async fn complete_messages( &self, messages: &[ServiceBusReceivedMessage], ) -> ServiceBusResult<()>

Complete multiple messages

pub async fn abandon_message( &self, message: &ServiceBusReceivedMessage, ) -> ServiceBusResult<()>

Abandon a single message

pub async fn abandon_messages( &self, messages: &[ServiceBusReceivedMessage], ) -> ServiceBusResult<()>

Abandon multiple messages

pub async fn dead_letter_message( &self, message: &ServiceBusReceivedMessage, reason: Option<String>, error_description: Option<String>, ) -> ServiceBusResult<()>

Dead letter a single message

pub async fn find_message( &self, message_id: &str, sequence_number: i64, max_position: Option<usize>, ) -> ServiceBusResult<Option<ServiceBusReceivedMessage>>

Find a specific message by ID and sequence number (used for targeted operations)

pub async fn dispose_consumer(&mut self) -> ServiceBusResult<()>

Dispose current consumer

pub fn get_raw_consumer(&self) -> Option<Arc<Mutex<Consumer>>>

Get raw consumer for advanced operations (used by bulk operations)

pub async fn reset_client( &mut self, new_client: Arc<Mutex<ServiceBusClient<BasicRetryPolicy>>>, ) -> ServiceBusResult<()>

Reset the ServiceBusClient reference after connection reset