pub async fn mark_failed( pool: &PgPool, id: i64, error: &str, next_retry: i64, now: i64, ) -> Result<(), Error>
mark a message as failed with next retry time