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

Publish AddressTerminated after a member is Downed/Removed, see #2779

Browse source 
* Instead of when unreachable

* Note that ClusterRouterConfig is not changed, i.e. routees will be removed
  when unreachable
* Routers that are not wrapped by ClusterRouterConfig will watch as usual, i.e.
  remove routees when Terminated, i.e. node down
This commit is contained in:
Patrik Nordwall 2012-12-10 15:10:40 +01:00
parent fa3a5c97de
commit 1cd3a05f41
3 changed files with 23 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-cluster/src/main/scala/akka/cluster/ClusterEvent.scala
View file

@ -296,9 +296,16 @@ private[cluster] final class ClusterDomainEventPublisher extends Actor with Acto
}
publish(event)
case MemberUnreachable(m) ⇒
case MemberDowned(m) ⇒
// TODO this case might be collapsed with MemberRemoved, see ticket #2788
// but right now we don't change Downed to Removed
publish(event)
// notify DeathWatch about unreachable node
// notify DeathWatch about downed node
publish(AddressTerminated(m.address))
case MemberRemoved(m) ⇒
publish(event)
// notify DeathWatch about removed node
publish(AddressTerminated(m.address))
case _ ⇒