aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/akka/ActorInstrumentation.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/akka/ActorInstrumentation.scala')
-rw-r--r--src/main/scala/akka/ActorInstrumentation.scala46
1 files changed, 0 insertions, 46 deletions
diff --git a/src/main/scala/akka/ActorInstrumentation.scala b/src/main/scala/akka/ActorInstrumentation.scala
deleted file mode 100644
index afe0e459..00000000
--- a/src/main/scala/akka/ActorInstrumentation.scala
+++ /dev/null
@@ -1,46 +0,0 @@
-package akka
-
-import actor.ActorCell
-import org.aspectj.lang.annotation.{After, Around, Pointcut, Aspect}
-import org.aspectj.lang.ProceedingJoinPoint
-import kamon.metric.Metrics.{ metricsRegistry => meterRegistry }
-import com.codahale.metrics.Meter
-import kamon.metric.MetricsUtils._
-
-@Aspect("perthis(actorCellCreation(*))")
-class ActorInstrumentation {
-
- /**
- * Aspect members
- */
-
- private val actorMeter:Meter = new Meter
-
- /**
- * Pointcuts
- */
- @Pointcut("execution(akka.actor.ActorCell+.new(..)) && this(actor)")
- def actorCellCreation(actor:ActorCell):Unit = {}
-
- @Pointcut("execution(* akka.actor.ActorCell+.receiveMessage(..))")
- def actorReceive():Unit = {}
-
- /**
- * Advices
- */
- @After("actorCellCreation(actor)")
- def afterCellCreation(actor:ActorCell):Unit ={
- val actorName:String = actor.self.path.toString
-
- meterRegistry.register(s"meter-for-${actorName}", actorMeter)
- }
-
- @Around("actorReceive()")
- def around(pjp: ProceedingJoinPoint) = {
- import pjp._
-
- markMeter(actorMeter) {
- proceed
- }
- }
- } \ No newline at end of file