akka.cluster.ddata

Class WriteAggregator

java.lang.Object

akka.cluster.ddata.ReadWriteAggregator

akka.cluster.ddata.WriteAggregator

All Implemented Interfaces:

Actor

public class WriteAggregator
extends ReadWriteAggregator

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from class akka.cluster.ddata.ReadWriteAggregator

ReadWriteAggregator.SendToSecondary$

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
WriteAggregator(Key<ReplicatedData> key, akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope, Replicator.WriteConsistency consistency, scala.Option<java.lang.Object> req, scala.collection.immutable.Set<Address> nodes, ActorRef replyTo, boolean durable)

Method Summary

Modifier and Type	Method and Description
protected static void	akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected static void	akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
protected static void	aroundPostRestart(java.lang.Throwable reason)
protected static void	aroundPostStop()
protected static void	aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void	aroundPreStart()
protected static void	aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
static ActorContext	context()
int	doneWhenRemainingSize()
boolean	gotLocalStoreReply()
scala.collection.immutable.Set<Address>	gotWriteNackFrom()
boolean	isDone()
scala.collection.immutable.Set<Address>	nodes()
boolean	notEnoughNodes()
static void	postRestart(java.lang.Throwable reason)
static void	postStop()
static void	preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
void	preStart() User overridable callback.
static scala.collection.immutable.Iterable<Address>	primaryNodes()
static Props	props(Key<ReplicatedData> key, akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope, Replicator.WriteConsistency consistency, scala.Option<java.lang.Object> req, scala.collection.immutable.Set<Address> nodes, ActorRef replyTo, boolean durable)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive() This defines the initial actor behavior, it must return a partial function with the actor logic.
static void	remaining_$eq(scala.collection.immutable.Set<Address> x$1)
static scala.collection.immutable.Set<Address>	remaining()
static ActorSelection	replica(Address address)
void	reply(boolean isTimeout)
static scala.collection.immutable.Iterable<Address>	secondaryNodes()
static ActorRef	self()
static ActorRef	sender()
Address	senderAddress()
static void	sendToSecondarySchedule_$eq(Cancellable x$1)
static Cancellable	sendToSecondarySchedule()
static SupervisorStrategy	supervisorStrategy()
scala.concurrent.duration.FiniteDuration	timeout()
static void	timeoutSchedule_$eq(Cancellable x$1)
static Cancellable	timeoutSchedule()
static void	unhandled(java.lang.Object message)
akka.cluster.ddata.Replicator.Internal.Write	writeMsg()

Methods inherited from class akka.cluster.ddata.ReadWriteAggregator

context, MaxSecondaryNodes, postStop, primaryNodes, remaining, replica, secondaryNodes, self, sendToSecondarySchedule, timeoutSchedule

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, sender, supervisorStrategy, unhandled

Constructor Detail

WriteAggregator

public WriteAggregator(Key<ReplicatedData> key,
                       akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope,
                       Replicator.WriteConsistency consistency,
                       scala.Option<java.lang.Object> req,
                       scala.collection.immutable.Set<Address> nodes,
                       ActorRef replyTo,
                       boolean durable)

Method Detail

props

public static Props props(Key<ReplicatedData> key,
                          akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope,
                          Replicator.WriteConsistency consistency,
                          scala.Option<java.lang.Object> req,
                          scala.collection.immutable.Set<Address> nodes,
                          ActorRef replyTo,
                          boolean durable)

sender

public static final ActorRef sender()

aroundReceive

protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
                                    java.lang.Object msg)

aroundPreStart

protected static void aroundPreStart()

aroundPostStop

protected static void aroundPostStop()

aroundPreRestart

protected static void aroundPreRestart(java.lang.Throwable reason,
                                       scala.Option<java.lang.Object> message)

aroundPostRestart

protected static void aroundPostRestart(java.lang.Throwable reason)

supervisorStrategy

public static SupervisorStrategy supervisorStrategy()

preRestart

public static void preRestart(java.lang.Throwable reason,
                              scala.Option<java.lang.Object> message)
                       throws java.lang.Exception

Throws:

java.lang.Exception

postRestart

public static void postRestart(java.lang.Throwable reason)
                        throws java.lang.Exception

Throws:

java.lang.Exception

unhandled

public static void unhandled(java.lang.Object message)

sendToSecondarySchedule

public static Cancellable sendToSecondarySchedule()

sendToSecondarySchedule_$eq

public static void sendToSecondarySchedule_$eq(Cancellable x$1)

timeoutSchedule

public static Cancellable timeoutSchedule()

timeoutSchedule_$eq

public static void timeoutSchedule_$eq(Cancellable x$1)

remaining

public static scala.collection.immutable.Set<Address> remaining()

remaining_$eq

public static void remaining_$eq(scala.collection.immutable.Set<Address> x$1)

primaryNodes

public static scala.collection.immutable.Iterable<Address> primaryNodes()

secondaryNodes

public static scala.collection.immutable.Iterable<Address> secondaryNodes()

postStop

public static void postStop()

replica

public static ActorSelection replica(Address address)

context

public static ActorContext context()

self

public static final ActorRef self()

akka$actor$Actor$_setter_$context_$eq

protected static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)

akka$actor$Actor$_setter_$self_$eq

protected static final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)

nodes

public scala.collection.immutable.Set<Address> nodes()

Specified by:

nodes in class ReadWriteAggregator

timeout

public scala.concurrent.duration.FiniteDuration timeout()

Specified by:

timeout in class ReadWriteAggregator

doneWhenRemainingSize

public int doneWhenRemainingSize()

Specified by:

doneWhenRemainingSize in class ReadWriteAggregator

writeMsg

public akka.cluster.ddata.Replicator.Internal.Write writeMsg()

gotLocalStoreReply

public boolean gotLocalStoreReply()

gotWriteNackFrom

public scala.collection.immutable.Set<Address> gotWriteNackFrom()

preStart

public void preStart()

Description copied from interface: Actor

User overridable callback.

Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.

Specified by:

preStart in interface Actor

Overrides:

preStart in class ReadWriteAggregator

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()

Description copied from interface: Actor

This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:

receive in interface Actor

Specified by:

receive in class ReadWriteAggregator

Returns:

(undocumented)

senderAddress

public Address senderAddress()

isDone

public boolean isDone()

notEnoughNodes

public boolean notEnoughNodes()

reply

public void reply(boolean isTimeout)