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

Fixing bug in preRestart pushing the envelope as message

Browse source
This commit is contained in:
Viktor Klang 2012-07-23 16:23:26 +02:00
parent 985d17de63
commit 47509668b1
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actor/src/main/scala/akka/actor/cell/FaultHandling.scala
View file

@ -51,10 +51,10 @@ private[akka] trait FaultHandling { this: ActorCell ⇒
if (failedActor ne null) {
try {
// if the actor fails in preRestart, we can do nothing but log it: it’s best-effort
if (failedActor.context ne null) failedActor.preRestart(cause, Option(currentMessage))
if (failedActor.context ne null) failedActor.preRestart(cause, Option(currentMessage.message))
} catch {
case NonFatal(e) ⇒
val ex = new PreRestartException(self, e, cause, Option(currentMessage))
val ex = new PreRestartException(self, e, cause, Option(currentMessage.message))
publish(Error(ex, self.path.toString, clazz(failedActor), e.getMessage))
} finally {
clearActorFields(failedActor)