Function redis_queue::manager::trim_queue_task

pub async fn trim_queue_task(queue: Queue, kind: ConsumerKind, retry_num: u32)

Wrapper for queue_trim_consumed to perform consuming logic depending on ConsumerKind of manager

This function is also guarded against performing multiple concurrent trims. If task is ongoing, it will skip trim and exit task early. Otherwise it starts trim with number of retries as specified via retry_num