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

Implementing buddy failover

Browse source
This commit is contained in:
Viktor Klang 2011-09-27 11:07:11 +02:00
parent a7cb5b5212
commit a7d73c3c40
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala
View file

@ -94,6 +94,9 @@ class BalancingDispatcher(
protected[akka] override def unregister(actor: ActorCell) = {
super.unregister(actor)
buddies.remove(actor)
val buddy = buddies.pollFirst()
if (buddy ne null)
registerForExecution(buddy.mailbox, false, false)
}
protected[akka] override def shutdown(): Unit = {
@ -122,10 +125,10 @@ class BalancingDispatcher(
val receiver = invocation.receiver
messageQueue enqueue invocation
registerForExecution(receiver.mailbox, true, false)
registerForExecution(receiver.mailbox, false, false)
val buddy = buddies.pollFirst()
if (buddy ne null)
registerForExecution(buddy.mailbox, true, false)
registerForExecution(buddy.mailbox, false, false)
}
}