Hi Benjamin, I also rely on cluster events and AFAIK you can expect (and trust) *MemberUp* and *MemberRemoved*, these IMHO are the only two consistent states you can trust. In other words, I register some actors only when their nodes reach *MemberUp* and unregister only when their nodes reach *MemberRemoved* Any other state in between I would treat them as information only.
So far I haven't got any issue with my mini-shard implementation relying on these only 2 statuses, the draw back is that it will only have to wait for a longer time to react. HTH, Guido. On Thursday, March 17, 2016 at 6:07:48 PM UTC, Benjamin Black wrote: > > Hello, > > I'm adding logic to our service so that when a node is being restarted it > gracefully leaves the cluster using cluster.leave(cluster.selfAddress). > In the cluster specification doc it states: > > If a node is unreachable then gossip convergence is not possible and > therefore any leader actions are also not possible (for instance, > allowing a node to become a part of the cluster). To be able to move > forward the state of theunreachable nodes must be changed. It must become > reachable again or marked as down > > Is this totally true? If a node is unreachable and is the > leaving/exiting/removed state will this stop the leader from adding a new > node? I ask because I have an actor that subscribes to cluster events and I > can see a node is being added whilst another node is considered unreachable > and in the exiting status: > > 14:02:46.843 INFO Exited member Member(address = akka.tcp:// > [email protected]:7000, status = Exiting) > 14:02:51.842 INFO Unreachable member Member(address = akka.tcp:// > [email protected]:7000, status = Exiting) > 14:02:53.843 INFO Removing member Member(address = akka.tcp:// > [email protected]:7000, status = Removed) > 14:02:57.843 INFO Exited member Member(address = akka.tcp:// > [email protected]:7000, status = Exiting) > 14:03:02.760 INFO Unreachable member Member(address = akka.tcp:// > [email protected]:7000, status = Exiting) > 14:03:04.843 INFO Adding member Member(address = akka.tcp:// > [email protected]:7000, status = Up) > > Thanks, > Ben > > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
