ResponseTimeLoggerActor

ResponsTimeLoggerActor.scala

object ResponseTimeLoggerActor {
  case object LogMeasures
}

trait ResponseTimeLoggerActor {
  x: Actor =>

  implicit val executionContext: ExecutionContextExecutor

  val logger: Logger

  val autoSchedule = true
  val autoScheduleTime = 5 seconds

  var min: Long = 0
  var max: Long = 0
  var count : Long = 0
  var averageResponse: Double = 0.0
  var firstMeasure: Long = 0

  abstract override def aroundReceive(receive: Receive, msg: Any): Unit = {
    val now = System.currentTimeMillis()
    if(firstMeasure == 0 && autoSchedule) {
      firstMeasure = now
      x.context.system.scheduler.scheduleOnce(autoScheduleTime, self, LogMeasures)
    }
    msg match {
      case LogMeasures =>
        logger.info(s"Actor response times ($firstMeasure - $now): Min: $min, Max: $max, count: $count, avgResponseTime: $averageResponse")
        min = 0
        max = 0
        count = 0
        averageResponse = 0
        firstMeasure = now
        x.context.system.scheduler.scheduleOnce(autoScheduleTime, self, LogMeasures)
      case _ =>
    }

    receive.apply(msg)

    val runtime = System.currentTimeMillis() - now
    averageResponse = (averageResponse * count + runtime) / (count + 1)
    count = count + 1
    min = Math.min(min, runtime)
    max = Math.max(max, runtime)
  }
}