aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/akka/ActorAspect.scala
blob: 744b0aea16823b1ef897b3cce02c17d5fbb14c9f (plain) (blame)
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
26
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 {
  println("Created ActorAspect")

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

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

    //println("The path is: "+actor.self.path.)
    val actorName:String  = actor.self.path.toString

    markAndCountMeter(actorName){
      pjp.proceed
    }

  }
}