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

Merge pull request #20828 from choffmeister/choffmeister-20826-unregister-leaving-distributed-pubsub-nodes

Browse source 
Remove distributed pubsub nodes on leave
This commit is contained in:
Patrik Nordwall 2016-07-05 15:48:07 +02:00 • committed by GitHub
commit f0f755bf08
1 changed files with 6 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala
View file

@ -676,6 +676,12 @@ class DistributedPubSubMediator(settings: DistributedPubSubSettings) extends Act
if (matchingRole(m)) if (matchingRole(m))
nodes += m.address nodes += m.address
case MemberLeft(m) ⇒
if (matchingRole(m)) {
nodes -= m.address
registry -= m.address
}
case MemberRemoved(m, _) ⇒ case MemberRemoved(m, _) ⇒
if (m.address == selfAddress) if (m.address == selfAddress)
context stop self context stop self