override def uncaughtException()

in src/main/scala/com/gu/kinesis/KinesisSource.scala [231:240]

• 9 lines of code
• 3 McCabe index (conditional complexity)

    override def uncaughtException(t: Thread, e: Throwable): Unit = {
      e match {
        case NonFatal(e) =>
          log.error(s"Uncaught exception in thread `${t.getName}`.", e)

        case _ =>
          log.error(s"Fatal error in thread `${t.getName}`, exiting VM.", e)
          System.exit(-1)
      }
    }