pub async fn consume( __arg0: State<AppState>, __arg1: Path<String>, headers: HeaderMap, ) -> Result<Response, AppError>