override def processLine()

in src/main/scala/com/twitter/iago/processor/SimpleRecordProcessor.scala [44:61]

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

  override def processLine(line: String) {
    Trace.traceService("Parrot", "SimpleRecordProcessor.processLine") {
      val p = UriParser(line)
      log.trace("SimpleRecordProcessor.processLine: line is %s", line)
      UriParser(line) match {
        case Return(uri) =>
          if (!uri.path.isEmpty && !line.startsWith("#"))
            service(new ParrotRequest(hostHeader, Nil, uri, line))
        case Throw(t) =>
          if (exceptionCount < 3)
            log.warning("exception\n\t%s\nwhile processing line\n\t%s", t.getMessage(), line)
          else if (exceptionCount == 3) log.warning("more exceptions ...")
          exceptionCount += 1
          badlines.incr()
          config.statsReceiver.counter("bad_lines/" + t.getClass.getName).incr()
      }
    }
  }