Akka 2.1 Cluster API

ClusteredApp.scala

val system = ActorSystem("ClusterSystem")

system.actorOf(Props(new Actor with ActorLogging { 
    
  val cluster = Cluster(context.system)
  
  override def preStart(): Unit = 
    cluster.subscribe(self, classOf[ClusterDomainEvent])
  
  def receive = {
    case state: CurrentClusterState => 
      log.info("Current members: {}", state.members)
    case MemberJoined(member)       => 
      log.info("Member joined: {}", member)
    case MemberUp(member)           => 
      log.info("Member is Up: {}", member)
    case MemberUnreachable(member)  => 
      log.info("Member detected as unreachable: {}", member)
    case MemberDowned(m)            => 
      log.info("Member detected as downed: {}", member)
    case MemberRemoved(m)           => 
      log.info("Member removed: {}", member)
    case _: ClusterDomainEvent      => // ignore
  }
  
  override def postStop: Unit = cluster unsubscribe self

  }), name = "clusterSampleListener")