Added cleanUp callback in Mailbox, dused in ZooKeeper. Some minor cleanup
This commit is contained in:
parent
cf675d29ce
commit
a6e75fb702
6 changed files with 19 additions and 16 deletions
|
|
@ -199,6 +199,7 @@ abstract class MessageDispatcher(val app: ActorSystem) extends Serializable {
|
|||
actor.mailbox = deadLetterMailbox
|
||||
mailBox.becomeClosed() // FIXME reschedule in tell if possible race with cleanUp is detected in order to properly clean up
|
||||
cleanUpMailboxFor(actor, mailBox)
|
||||
mailBox.cleanUp()
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue