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

correct cleanupMailboxFor to reset the system messages before enqueuing

Browse source
This commit is contained in:
Roland 2011-11-11 17:55:17 +01:00
parent aedb319484
commit e5c3b39502
1 changed files with 2 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/akka/dispatch/AbstractDispatcher.scala
View file

@ -222,7 +222,9 @@ abstract class MessageDispatcher(val app: ActorSystem) extends Serializable {
if (mailBox.hasSystemMessages) {
var message = mailBox.systemDrain()
while (message ne null) {
// message must be “virgin” before being able to systemEnqueue again
val next = message.next
message.next = null
deadLetterMailbox.systemEnqueue(message)
message = next
}