Second stab at revised error handling. See #1310

2012-01-31 14:44:14 +01:00 · 2012-01-31 14:44:14 +01:00 · f13b5356f7
commit f13b5356f7
parent 4c2a44ec7a
9 changed files with 152 additions and 50 deletions
--- a/akka-actor/src/main/scala/akka/dispatch/Mailbox.scala
+++ b/akka-actor/src/main/scala/akka/dispatch/Mailbox.scala
@ -197,7 +197,7 @@ private[akka] abstract class Mailbox(val actor: ActorCell) extends MessageQueue
        if (nextMessage eq null) nextMessage = systemDrain()
      }
    } catch {
-      case e ⇒
+      case NonFatal(e) ⇒
        actor.system.eventStream.publish(Error(e, actor.self.path.toString, this.getClass, "exception during processing system messages, dropping " + SystemMessage.size(nextMessage) + " messages!"))
        throw e
    }