tailrec

gistfile1

        @tailrec
        def fetchWithRetries(retries: Int): MultiFetchResponse = {
          val resultMaybe = catching(classOf[IOException]) either {
            simpleConsumer.multifetch(fetches : _*)
          }
          resultMaybe match{
            case Left(e) =>
              if(retries > 0) {
                info("Unable to complete multifetch. Sleeping for %dms".format(config.fetcherBackoffMs), e)
                Utils.swallow(logger.info, Thread.sleep(config.fetcherBackoffMs))
                fetchWithRetries(retries - 1)
              } else {
                throw e
              }
            case Right(result) => result
          }
        }