public abstract class ReadWriteAggregator
extends java.lang.Object
implements akka.actor.Actor
Modifier and Type | Class and Description |
---|---|
static class |
ReadWriteAggregator.SendToSecondary$ |
Constructor and Description |
---|
ReadWriteAggregator() |
Modifier and Type | Method and Description |
---|---|
abstract int |
doneWhenRemainingSize() |
static int |
MaxSecondaryNodes() |
abstract scala.collection.immutable.Set<akka.actor.Address> |
nodes() |
void |
postStop() |
scala.collection.immutable.Iterable<akka.actor.Address> |
primaryNodes() |
scala.collection.immutable.Set<akka.actor.Address> |
remaining() |
akka.actor.ActorSelection |
replica(akka.actor.Address address) |
scala.collection.immutable.Iterable<akka.actor.Address> |
secondaryNodes() |
akka.actor.Cancellable |
sendToSecondarySchedule() |
abstract scala.concurrent.duration.FiniteDuration |
timeout() |
akka.actor.Cancellable |
timeoutSchedule() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
public static int MaxSecondaryNodes()
public abstract scala.concurrent.duration.FiniteDuration timeout()
public abstract scala.collection.immutable.Set<akka.actor.Address> nodes()
public akka.actor.Cancellable sendToSecondarySchedule()
public akka.actor.Cancellable timeoutSchedule()
public scala.collection.immutable.Set<akka.actor.Address> remaining()
public abstract int doneWhenRemainingSize()
public scala.collection.immutable.Iterable<akka.actor.Address> primaryNodes()
public scala.collection.immutable.Iterable<akka.actor.Address> secondaryNodes()
public void postStop()
postStop
in interface akka.actor.Actor
public akka.actor.ActorSelection replica(akka.actor.Address address)