def start()

in src/main/scala/com/twitter/iago/server/RequestQueue.scala [69:90]

• 22 lines of code
• 7 McCabe index (conditional complexity)

  def start(): Future[Unit] = {
    log.debug("starting RequestQueue")
    transport respond {
      case Return(response) =>
        transport.stats(response).foreach {
          _.foreach { rep =>
            scopedStats.counter(rep).incr()
          }
        }
      case Throw(t) =>
        t match {
          case e: ConnectException =>
            if (e.getMessage.contains("timed out")) responseTimeout.incr()
            if (e.getMessage.contains("refused")) connectionRefused.incr()
          case _ =>
            unexpectedError.incr()
            scopedStats.counter("unexpected_error/" + t.getClass.getName).incr()
            log.error("unexpected error: %s", t)
        }
    }
    consumer.run()
  }