Trait ServiceBusClientExt 

pub trait ServiceBusClientExt {
    // Required method
    fn create_consumer_for_queue(
        &mut self,
        queue_name: impl Into<String> + Send,
        options: ServiceBusReceiverOptions,
    ) -> impl Future<Output = Result<Consumer, Error>>;
}

Extension trait for ServiceBusClient to create Consumer instances.

This trait provides a convenient method to create a Consumer directly from a ServiceBusClient without manually creating the receiver first.

Required Methods

fn create_consumer_for_queue( &mut self, queue_name: impl Into<String> + Send, options: ServiceBusReceiverOptions, ) -> impl Future<Output = Result<Consumer, Error>>

Creates a Consumer for the specified queue.

Arguments

• queue_name - Name of the queue to create a consumer for
• options - Configuration options for the receiver

Returns

A Consumer instance configured for the specified queue

Errors

Returns an error if the receiver creation fails

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<RP> ServiceBusClientExt for ServiceBusClient<RP>

where RP: ServiceBusRetryPolicy + From<ServiceBusRetryOptions> + Send + Sync + 'static,

async fn create_consumer_for_queue( &mut self, queue_name: impl Into<String> + Send, options: ServiceBusReceiverOptions, ) -> Result<Consumer, Error>

Creates a Consumer for the specified queue using this ServiceBusClient.

This method handles the creation of the underlying receiver and wraps it in a Consumer instance for easier usage.

Implementors