diff options
Diffstat (limited to 'src/main/scala/akka/instrumentation/ActorInstrumentation.scala')
-rw-r--r-- | src/main/scala/akka/instrumentation/ActorInstrumentation.scala | 23 |
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 |