@tailrec
  def retryOn[T](thCls: Class[_ <: Throwable], maxTimes: Int, delayBetweenRetries: Int = 0, onRetry: => Unit = {})(block: => T): T = {
    try block
    catch {
      case t: Throwable if thCls.isInstance(t) && maxTimes > 0 =>
        onRetry
        Thread.sleep(delayBetweenRetries)
        retryOn(thCls, maxTimes - 1, delayBetweenRetries, onRetry)(block)
    }
  }