From 54bed05e58ec859e76ba57545e22ba53a38cb916 Mon Sep 17 00:00:00 2001 From: Vasil Remeniuk Date: Sun, 14 Aug 2011 11:20:38 +0300 Subject: [PATCH] more logging --- akka-actor/src/main/scala/akka/actor/Actor.scala | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/akka-actor/src/main/scala/akka/actor/Actor.scala b/akka-actor/src/main/scala/akka/actor/Actor.scala index d00ca86adb..e67d1aa0d4 100644 --- a/akka-actor/src/main/scala/akka/actor/Actor.scala +++ b/akka-actor/src/main/scala/akka/actor/Actor.scala @@ -429,12 +429,12 @@ object Actor { private[akka] def createActor(address: String, actorFactory: () ⇒ ActorRef): ActorRef = { Address.validate(address) registry.actorFor(address) match { // check if the actor for the address is already in the registry - case Some(actorRef) ⇒ actorRef // it is -> return it + case Some(actorRef) ⇒ println(address + ": FOund in registry!!"); actorRef // it is -> return it case None ⇒ // it is not -> create it try { Deployer.deploymentFor(address) match { - case Deploy(_, _, router, Local) ⇒ actorFactory() // create a local actor - case deploy ⇒ newClusterActorRef(actorFactory, address, deploy) + case Deploy(_, _, router, Local) ⇒ println(address + ": CREATE LOCALLY!!"); actorFactory() // create a local actor + case deploy ⇒ println(address + ": CREATE CLUSTER!!"); newClusterActorRef(actorFactory, address, deploy) } } catch { case e: DeploymentException ⇒ @@ -594,11 +594,11 @@ trait Actor { } /* - * Option[ActorRef] representation of the 'self' ActorRef reference. - *

- * Mainly for internal use, functions as the implicit sender references when invoking - * one of the message send functions ('!' and '?'). - */ + * Option[ActorRef] representation of the 'self' ActorRef reference. + *

+ * Mainly for internal use, functions as the implicit sender references when invoking + * one of the message send functions ('!' and '?'). + */ def optionSelf: Option[ActorRef] = someSelf /**