pub async fn queue_registry_handler( handler_type: &str, fun: fn(&ProcessTask) -> Pin<Box<dyn Future<Output = ()>>>, )