Renaming InVMMonitoring to LocalDeathWatch and moved it into AkkaApplication, also created a createDeathWatch method in ActorRefProvider so that it's seeded from there, and then removed @volatile from alot of vars in ActorCell since the fields are now protected by the Mailbox status field
This commit is contained in:
parent
3a543ed23d
commit
3dc84a0229
7 changed files with 42 additions and 34 deletions
|
|
@ -121,8 +121,11 @@ class Dispatcher(
|
|||
true
|
||||
} catch {
|
||||
case e: RejectedExecutionException ⇒
|
||||
app.eventHandler.warning(this, e.toString)
|
||||
mbox.setAsIdle()
|
||||
try {
|
||||
app.eventHandler.warning(this, e.toString)
|
||||
} finally {
|
||||
mbox.setAsIdle()
|
||||
}
|
||||
throw e
|
||||
}
|
||||
} else false
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue