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

merged with upstream

Browse source
This commit is contained in:
Jonas Boner 2010-08-16 14:19:32 +02:00
parent 565446d2fd
commit 19ac69fda4
1 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-core/src/main/scala/actor/ActorRef.scala
View file

@ -27,6 +27,7 @@ import java.util.concurrent.atomic.AtomicReference
import java.util.concurrent.{ScheduledFuture, ConcurrentHashMap, TimeUnit}
import java.util.{Map => JMap}
import java.lang.reflect.Field
import scala.reflect.BeanProperty
import com.google.protobuf.ByteString
@ -1261,7 +1262,12 @@ class LocalActorRef private[akka](
if (topLevelTransaction) clearTransactionSet
if (supervisor.isDefined) notifySupervisorWithMessage(Exit(this, reason))
else lifeCycle match { case Some(LifeCycle(Temporary)) => shutDownTemporaryActor(this) }
else {
lifeCycle match {
case Some(LifeCycle(Temporary)) => shutDownTemporaryActor(this)
case _ =>
}
}
}
private def notifySupervisorWithMessage(notification: LifeCycleMessage) = {
@ -1675,4 +1681,4 @@ trait ScalaActorRef extends ActorRefShared { ref: ActorRef =>
*/
def spawnLinkRemote[T <: Actor : Manifest](hostname: String, port: Int): ActorRef =
spawnLinkRemote(manifest[T].erasure.asInstanceOf[Class[_ <: Actor]],hostname,port)
}
}