Struct QueueManager 

pub struct QueueManager { /* private fields */ }

Implementations

impl QueueManager

pub fn new(driver: Box<dyn QueueInterface>) -> Self

Creates a new QueueManager wrapping a specific driver implementation.

pub async fn add_to_queue(&self, queue_name: &str, data: JobData) -> Result<()>

Adds data to the specified queue via the underlying driver.

pub async fn process_queue( &self, queue_name: &str, callback: JobProcessorFnAsync, ) -> Result<()>

Registers a processor for the specified queue and starts processing (if applicable for the driver).

pub async fn disconnect(&self) -> Result<()>

Disconnects the underlying driver (if necessary).

pub async fn check_health(&self) -> Result<()>

Checks the health of the underlying queue driver.