src/main/scala/akka/ActorAspect.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

package akka

import org.aspectj.lang.annotation.{Around, Pointcut, Aspect}
import org.aspectj.lang.ProceedingJoinPoint
import kamon.metric.Metrics
import akka.actor.ActorCell

@Aspect
class ActorAspect extends Metrics {

  @Pointcut("execution(* akka.actor.ActorCell+.receiveMessage(..))")
  protected def actorReceive:Unit = {}

  @Around("actorReceive() && this(actor)")
  def around(pjp: ProceedingJoinPoint, actor: akka.actor.ActorCell): AnyRef = {

    val actorName:String  = actor.self.path.toString

    markAndCountMeter(actorName){
      pjp.proceed
    }

  }
}