akka.cluster
Class ClusterEvent$

java.lang.Object
  akka.cluster.ClusterEvent$

public class ClusterEvent$
extends java.lang.Object

Domain events published to the event bus. Subscribe with:

   Cluster(system).subscribe(actorRef, classOf[ClusterDomainEvent])
 

Field Summary

static ClusterEvent$

MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

ClusterEvent$()

Method Summary

scala.collection.immutable.Seq<ClusterEvent.LeaderChanged>	diffLeader(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress) INTERNAL API
scala.collection.immutable.Seq<ClusterEvent.MemberEvent>	diffMemberEvents(Gossip oldGossip, Gossip newGossip) INTERNAL API.
scala.collection.immutable.Seq<ClusterEvent.ReachabilityChanged>	diffReachability(Gossip oldGossip, Gossip newGossip) INTERNAL API
scala.collection.immutable.Seq<ClusterEvent.ReachableMember>	diffReachable(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress) INTERNAL API
scala.collection.immutable.Set<ClusterEvent.RoleLeaderChanged>	diffRolesLeader(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress) INTERNAL API
scala.collection.immutable.Seq<ClusterEvent.SeenChanged>	diffSeen(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress) INTERNAL API
scala.collection.immutable.Seq<ClusterEvent.UnreachableMember>	diffUnreachable(Gossip oldGossip, Gossip newGossip, UniqueAddress selfUniqueAddress) INTERNAL API
ClusterEvent.ClusterShuttingDown$	getClusterShuttingDownInstance() Java API: get the singleton instance of ClusterShuttingDown event
ClusterEvent.InitialStateAsEvents$	initialStateAsEvents() Java API
ClusterEvent.InitialStateAsSnapshot$	initialStateAsSnapshot() Java API

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final ClusterEvent$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ClusterEvent$

public ClusterEvent$()

Method Detail

initialStateAsSnapshot

public ClusterEvent.InitialStateAsSnapshot$ initialStateAsSnapshot()

Java API

Returns:

(undocumented)

initialStateAsEvents

public ClusterEvent.InitialStateAsEvents$ initialStateAsEvents()

Java API

Returns:

(undocumented)

getClusterShuttingDownInstance

public ClusterEvent.ClusterShuttingDown$ getClusterShuttingDownInstance()

Java API: get the singleton instance of ClusterShuttingDown event

Returns:

(undocumented)

diffUnreachable

public scala.collection.immutable.Seq<ClusterEvent.UnreachableMember> diffUnreachable(Gossip oldGossip,
                                                                                      Gossip newGossip,
                                                                                      UniqueAddress selfUniqueAddress)

INTERNAL API

Parameters:

oldGossip - (undocumented)

newGossip - (undocumented)

selfUniqueAddress - (undocumented)

Returns:

(undocumented)

diffReachable

public scala.collection.immutable.Seq<ClusterEvent.ReachableMember> diffReachable(Gossip oldGossip,
                                                                                  Gossip newGossip,
                                                                                  UniqueAddress selfUniqueAddress)

INTERNAL API

Parameters:

oldGossip - (undocumented)

newGossip - (undocumented)

selfUniqueAddress - (undocumented)

Returns:

(undocumented)

diffMemberEvents

public scala.collection.immutable.Seq<ClusterEvent.MemberEvent> diffMemberEvents(Gossip oldGossip,
                                                                                 Gossip newGossip)

INTERNAL API.

Parameters:

oldGossip - (undocumented)

newGossip - (undocumented)

Returns:

(undocumented)

diffLeader

public scala.collection.immutable.Seq<ClusterEvent.LeaderChanged> diffLeader(Gossip oldGossip,
                                                                             Gossip newGossip,
                                                                             UniqueAddress selfUniqueAddress)

INTERNAL API

Parameters:

oldGossip - (undocumented)

newGossip - (undocumented)

selfUniqueAddress - (undocumented)

Returns:

(undocumented)

diffRolesLeader

public scala.collection.immutable.Set<ClusterEvent.RoleLeaderChanged> diffRolesLeader(Gossip oldGossip,
                                                                                      Gossip newGossip,
                                                                                      UniqueAddress selfUniqueAddress)

INTERNAL API

Parameters:

oldGossip - (undocumented)

newGossip - (undocumented)

selfUniqueAddress - (undocumented)

Returns:

(undocumented)

diffSeen

public scala.collection.immutable.Seq<ClusterEvent.SeenChanged> diffSeen(Gossip oldGossip,
                                                                         Gossip newGossip,
                                                                         UniqueAddress selfUniqueAddress)

INTERNAL API

Parameters:

oldGossip - (undocumented)

newGossip - (undocumented)

selfUniqueAddress - (undocumented)

Returns:

(undocumented)

diffReachability

public scala.collection.immutable.Seq<ClusterEvent.ReachabilityChanged> diffReachability(Gossip oldGossip,
                                                                                         Gossip newGossip)

INTERNAL API

Parameters:

oldGossip - (undocumented)

newGossip - (undocumented)

Returns:

(undocumented)