aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/akka/instrumentation/ActorInstrumentation.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/akka/instrumentation/ActorInstrumentation.scala')
-rw-r--r--src/main/scala/akka/instrumentation/ActorInstrumentation.scala23
1 files changed, 23 insertions, 0 deletions
diff --git a/src/main/scala/akka/instrumentation/ActorInstrumentation.scala b/src/main/scala/akka/instrumentation/ActorInstrumentation.scala
new file mode 100644
index 00000000..ea599891
--- /dev/null
+++ b/src/main/scala/akka/instrumentation/ActorInstrumentation.scala
@@ -0,0 +1,23 @@
+package akka.instrumentation
+
+import org.aspectj.lang.annotation.{Before, Around, Pointcut, Aspect}
+import org.aspectj.lang.ProceedingJoinPoint
+import kamon.metric.Metrics
+import akka.actor.ActorCell
+
+@Aspect
+class ActorInstrumentation {
+ println("Created ActorAspect")
+
+ @Pointcut("execution(* kamon.executor.PingActor.receive(..))")
+ protected def actorReceive:Unit = {}
+
+ @Before("actorReceive() && args(message)")
+ def around(message: Any) = {
+ println("Around the actor cell receive")
+ //pjp.proceed(Array(Wrapper(message)))
+ //pjp.proceed
+ }
+}
+
+case class Wrapper(content: Any) \ No newline at end of file