public final class ClusterDomainEventPublisher
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging, akka.dispatch.RequiresMessageQueue<akka.dispatch.UnboundedMessageQueueSemantics>
Constructor and Description |
---|
ClusterDomainEventPublisher() |
Modifier and Type | Method and Description |
---|---|
void |
clearState() |
akka.event.EventStream |
eventStream() |
Gossip |
latestGossip() |
void |
postStop() |
void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
void |
publish(java.lang.Object event) |
void |
publishChanges(Gossip newGossip) |
void |
publishDiff(Gossip oldGossip,
Gossip newGossip,
scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> pub) |
void |
publishInternalStats(ClusterEvent.CurrentInternalStats currentStats) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
UniqueAddress |
selfUniqueAddress() |
void |
sendCurrentClusterState(akka.actor.ActorRef receiver)
The current snapshot state corresponding to latest gossip
to mimic what you would have seen if you were listening to the events.
|
void |
subscribe(akka.actor.ActorRef subscriber,
ClusterEvent.SubscriptionInitialStateMode initMode,
scala.collection.immutable.Set<java.lang.Class<?>> to) |
void |
unsubscribe(akka.actor.ActorRef subscriber,
scala.Option<java.lang.Class<?>> to) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public UniqueAddress selfUniqueAddress()
public Gossip latestGossip()
public void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
preRestart
in interface akka.actor.Actor
public void postStop()
postStop
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public akka.event.EventStream eventStream()
public void sendCurrentClusterState(akka.actor.ActorRef receiver)
receiver
- (undocumented)public void subscribe(akka.actor.ActorRef subscriber, ClusterEvent.SubscriptionInitialStateMode initMode, scala.collection.immutable.Set<java.lang.Class<?>> to)
public void unsubscribe(akka.actor.ActorRef subscriber, scala.Option<java.lang.Class<?>> to)
public void publishChanges(Gossip newGossip)
public void publishDiff(Gossip oldGossip, Gossip newGossip, scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> pub)
public void publishInternalStats(ClusterEvent.CurrentInternalStats currentStats)
public void publish(java.lang.Object event)
public void clearState()