Skip to content
Permalink
Branch: master
Find file Copy path
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
47 lines (38 sloc) 1.29 KB
/*
* Copyright (C) 2018-2019 Lightbend Inc. <https://www.lightbend.com>
*/
package docs.cluster
import akka.actor.{ Actor, ActorLogging }
import akka.cluster.Cluster
import akka.cluster.ClusterEvent._
class SimpleClusterListener2 extends Actor with ActorLogging {
//#join
val cluster = Cluster(context.system)
//#join
// subscribe to cluster changes, re-subscribe when restart
override def preStart(): Unit = {
//#join
cluster.join(cluster.selfAddress)
//#join
//#subscribe
cluster.subscribe(self, classOf[MemberEvent], classOf[UnreachableMember])
//#subscribe
//#register-on-memberup
cluster.registerOnMemberUp {
cluster.subscribe(self, classOf[MemberEvent], classOf[UnreachableMember])
}
//#register-on-memberup
}
override def postStop(): Unit = cluster.unsubscribe(self)
def receive = {
case state: CurrentClusterState =>
log.info("Current members: {}", state.members.mkString(", "))
case MemberUp(member) =>
log.info("Member is Up: {}", member.address)
case UnreachableMember(member) =>
log.info("Member detected as unreachable: {}", member)
case MemberRemoved(member, previousStatus) =>
log.info("Member is Removed: {} after {}", member.address, previousStatus)
case _: MemberEvent => // ignore
}
}
You can’t perform that action at this time.