diff options
Diffstat (limited to 'src/main/scala/akka/ActorSystemAspect.scala')
-rw-r--r-- | src/main/scala/akka/ActorSystemAspect.scala | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/main/scala/akka/ActorSystemAspect.scala b/src/main/scala/akka/ActorSystemAspect.scala index ce00d973..9d1d515d 100644 --- a/src/main/scala/akka/ActorSystemAspect.scala +++ b/src/main/scala/akka/ActorSystemAspect.scala @@ -1,18 +1,18 @@ package akka import org.aspectj.lang.annotation._ -import akka.actor.ActorSystemImpl -import com.typesafe.config.Config +import actor.ActorSystemImpl @Aspect -@DeclarePrecedence("ActorSystemAspect") class ActorSystemAspect { + println("Created ActorSystemAspect") - var currentActorSystem:ActorSystemImpl = _ - - @Pointcut("execution(akka.actor.ActorSystemImpl.new(..)) && !within(ActorSystemAspect)") + @Pointcut("execution(* akka.actor.ActorRefProvider+.init(..)) && !within(ActorSystemAspect)") protected def actorSystem():Unit = {} - @Before("actorSystem() && this(system) && args(name, config, classLoader)") - def collectActorSystem(system: ActorSystemImpl, name: String, config: Config, classLoader: ClassLoader) { currentActorSystem = system } + @After("actorSystem() && args(system)") + def collectActorSystem(system: ActorSystemImpl):Unit = { + Tracer.collectActorSystem(system) + Tracer.start() + } } |