Struct BulkOperationContext

pub struct BulkOperationContext {
    pub consumer: Arc<Mutex<Consumer>>,
    pub cancel_token: CancellationToken,
    pub queue_name: String,
}

Bulk operation context containing shared resources

Fields

consumer: Arc<Mutex<Consumer>>

cancel_token: CancellationToken

queue_name: String

Name of the queue this operation is targeting (used for deferred message persistence)

Trait Implementations

impl Clone for BulkOperationContext

fn clone(&self) -> BulkOperationContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BulkOperationContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.