src/main/scala/akka/actor/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
25

package akka.actor

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

@Aspect
class ActorAspect extends Metrics {


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

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


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

    markAndCountMeter(actorName){
      pjp.proceed
    }

  }
}