raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

more logging

Browse source
This commit is contained in:
Vasil Remeniuk 2011-08-14 11:20:38 +03:00
parent d52d70540c
commit 54bed05e58
1 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-actor/src/main/scala/akka/actor/Actor.scala
View file

@ -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.
* <p/>
* 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.
* <p/>
* Mainly for internal use, functions as the implicit sender references when invoking
* one of the message send functions ('!' and '?').
*/
def optionSelf: Option[ActorRef] = someSelf
/**